how to track the messages processed within a Kafka topic