Kafka Consumer customer.position повешение - PullRequest
Новая
       10

Kafka Consumer customer.position повешение

0 голосов
/ 24 октября 2018

Я пытаюсь получить последнее смещение от потребителя Кафки.Я делаю следующие 2 шага 

consumer.seekToEnd(partitionsArray)
consumer.position(partition)

Он отлично работает для тем в версии kafka kafka_2.9.1-0.8.2.1.Но не работает для тем в версии kafka_2.8.0-0.8.1.1.Для этой версии consumer.position(partition) просто продолжает работать.

Я использую класс KafkaConsumer из приведенной ниже версии 

'org.apache.kafka', name: 'kafka-tools', version: '0.9.0.0'

Может кто-нибудь помочь, пожалуйста?

Я также пытаюсь перечислить темы и разделы дляобе версии кафки.Это прекрасно работает для обеих версий, что показывает, что нет проблем с подключением к kafka как таковому.Проблема возникает только по методу consumer.position(partition)

...