Что ответит kafka, если я использую функции, которые kafka-jms-client не поддерживает?

Question

Я хочу использовать kafka-jms-client для замены моего текущего jms-брокера. Согласно документации некоторые функции не поддерживаются, такие как фиксация или откат. Что произойдет, когда клиент вызовет коммит или откат? Этот API просто отвечает нормально, но на самом деле ничего не делает со стороны Кафки?

Answer 1

Просмотр исходного кода показывает, что реализации javax.jms.Session.commit() и javax.jms.Session.rollback() для клиента Kafka JMS ничего не делают.

Здесь реализация rollback(), а реализация commit() (которая вызывает commit() в KafkaMessageConsumer).Как видите, оба метода в конечном итоге ничего не делают.Они просто вернутся, как будто все работает.

Многие другие методы в реализации javax.jms.Session следуют этому же шаблону.