Closed andrus closed 4 years ago
Using TopicConsumer, somehow the first message in a new queue is never received. Not necessarily a bug in the consumer code. But perhaps we can help the users to establish proper offset.
consumer = TopicConsumer .builder(keyDecoder, valueDecoder) .configName(KAFKA_CONSUMER_CONFIG) .group(KAFKA_CONSUMER_GROUP) .threads(THREADS) .topic(TOPIC) .build(consumerFactory.get()); consumer.consumeAll(..., ...).get();
Won't fix. No longer supporting Kafka 0.8
Using TopicConsumer, somehow the first message in a new queue is never received. Not necessarily a bug in the consumer code. But perhaps we can help the users to establish proper offset.