confluentinc / confluentinc/kafka-tutorials
Ksql example to count messages is irritating
Open
- Dominant language
- Java
- Stars
- 39
- Forks
- 91
- PR merge metrics
- No merged PRs in 30d
Description
The example uses limit 1 which will give a random massage count, since the query is **NOT** processing all message. Without limit 1, after some second one have the correct count.
`SELECT 'X' AS X,
COUNT(*) AS MSG_CT
FROM TOPIC
GROUP BY 'X'
EMIT CHANGES LIMIT 1;`
Can anyone explain, why the behavior is diffrent to whats describe in the example?
Contributor guide
Assessment
This issue has not been assessed yet.