Почему Java Kafka Consumer возвращает пустой список записей? - PullRequest
Новая
       43

Почему Java Kafka Consumer возвращает пустой список записей?

1 голос
/ 03 июля 2019

У меня есть приложение, которое реализует API, как GET / themes / (строка: имя_позиции) / partitions / (int: partition_id) / messages? Offset = (int) [& count = (int)] изConfluent REST Proxy для Kafka.

Итак, у меня есть пул потребителей.Мой обработчик API довольно прост:

  1. Получить получателя из пула
  2. consumer.assign(util.Arrays.asList(partition))
  3. consumer.seek(partition, startOffset)
  4. consumer.poll(Duration.ofMillis(300L))
  5. consumer.unsubscribe()
  6. Возврат потребителя в пул

Итак, мое решение работает довольно хорошо в течение нескольких дней.Затем что-то происходит, и poll() всегда возвращает пустой список записей.

Я могу это исправить, чтобы перезапустить свое приложение.Кроме того, я могу запустить новый экземпляр приложения, и этот может читать записи из Какфа, так что Кафка жив.

...