Пример реализации шаблона Spring Kafka для смещения поиска, подтверждения

Я новичок в spring-kafka-template. Я попробовал некоторые основные вещи в нем, и они работают нормально. Но я пытаюсь реализовать некоторые концепции, упомянутые в Документы Spring, такие как:

  1. Поиск смещения
  2. Благодарность слушателей

Я попытался найти какой-нибудь пример для него в сети, но безуспешно. Единственное, что я нашел, это его исходный код.

У нас та же проблема, что и в этом сообщении Spring kafka Consumer, поиск смещения во время выполнения .

Но нет доступного примера для реализации того же самого.

Может ли кто-нибудь привести пример того, как их реализовать?

Заранее спасибо.


spring-boot apache-kafka spring spring-kafka
person Abhishek Verma    schedule 15.06.2017    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Вы должны использовать ConsumerSeekAware для этой цели, чтобы иметь дело с поиском:

static class Listener implements ConsumerSeekAware {

     private final ThreadLocal<ConsumerSeekCallback> seekCallBack = new ThreadLocal<>();

     public void registerSeekCallback(ConsumerSeekCallback callback) {
        this.seekCallBack.set(callback);
    }

@KafkaListener(...)
        public void listen(@Payload String foo,
                Acknowledgment ack) {

                this.seekCallBack.get().seek(topic, partition, 0);
            }
        }

}
person Artem Bilan    schedule 15.06.2017