Count mismatch in AKHQ UI 0.24.0
I am producing 10 records to kafka topic and able to consume all 10 but in AKHQ UI I am seeing count as 12 . If I count the values manually its 10 only (same as what's produced).
PFA
Tried changing sort Order to newest but didn't help .
Also observed 12 data is shown in offset when checked in data 153-161 offset have only 7 records and 132-136 have only 3 records (please refer image 3 )
Solution
Transaction markers are unique offsets in Kafka that'll automatically be skipped by consumers, but naive offset counting cannot exclude them
- Kafka Best Practices + how to set recommended setting for JVM
- Connect to Kafka on host from Docker (ksqlDB)
- During rolling upgrade/restart, how to detect when a kafka broker is "done"?
- Kafka Connect running out of heap space
- Fault-tolerant queue-worker architecture in Kafka?
- Out of Memory issue when running a beam streaming pipeline using gcp dataflow with Kafka as a Source
- How do I test that an offset has been committed or not to Kafka
- Does it make sense to have a single send inside a kafka transaction using spring kafka?
- NullPointerException in Kafka-Connect service logs on start of Kafka-Connect
- Extracting Key and Appending It to the Message Value in Kafka Connect
- Confluent-Kafka: no broker available for coordinator query: intervaled in state query-coord
- DefaultAfterRollbackProcessor without BackOff for batch listener
- Searching messages in large kafka topic
- kafka-acls.sh Command Fails with Operations Containing Underscores in Kafka 2.7.0
- how to send batched data with Spring Kafka producer
- How can i enable kafka metrics in Kafka streams spring boot app
- Count mismatch in AKHQ UI 0.24.0
- Debezium KafkaConnect, kafka_connect_run.sh No such file or directory
- In docker-compose, my init-kafka image is failing to list topics on my kafka image. How do I fix this? (With KRaft, not Zookeeper!)
- Send custom message to Kafka topic
- Error connecting to kafka broker as a k8s pod on local machine
- How to access Kafka Connect created by Strimzi?
- Kafka message validation in ErrorHandlingDeserializer
- Issues Sending Kafka and Zookeeper Metrics to AWS CloudWatch Using JMX and CloudWatch Agent
- Kafka - Broker fails because all log dirs have failed
- NPM install node-rdkafka fails with node-gyp rebuild error
- Serialization in Kafka
- Unknown Magic Byte - Kafka Json
- Monitor the lag for the consumers that are assigned to partitions topic
- Kafka compact cleanup policy and config that could cleanup if segment is to big