пользовательский потребитель kafka для чтения входящих записей

#java #apache-kafka #kafka-consumer-api #java #apache-kafka #kafka-consumer-api Вопрос: Я создал потребителя kafka, используя новый API (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html) В настоящее время потребитель читает сообщения из темы, начиная с наименьшего смещения. Я хочу переопределить…

Продолжить чтениепользовательский потребитель kafka для чтения входящих записей