Передача подтверждения весеннему методу потребительского кафкалистенераJAVA

Программисты JAVA общаются здесь
Anonymous
Передача подтверждения весеннему методу потребительского кафкалистенера

Сообщение Anonymous »

Я пытаюсь отключить автомимирование в Кафке и вместо этого делать это вручную. С этой целью, в моем приложении.

Код: Выделить всё

@KafkaListener(id="${"+ KafkaConfiguration.APP_REQUEST_ID +"}", topics = "${"+KafkaConfiguration.PPA_REQUEST_TOPIC +"}")
public void receive(@Payload String message,
@Headers MessageHeaders headers)
Насколько я понимаю, для того, чтобы вручную совершить, мне нужен доступ к объекту подтверждения , который будет передаваться в качестве параметра моего метода cheact () . Мой вопрос: если я изменяю заголовок на < /p>

Код: Выделить всё

@KafkaListener(id="${"+ KafkaConfiguration.APP_REQUEST_ID +"}", topics = "${"+KafkaConfiguration.APP_REQUEST_TOPIC +"}")
public void receive(@Payload String message,
@Headers MessageHeaders headers,
Acknowledgment acknowledgment)
будет автоматически передаваться подтверждение или есть другие изменения, которые мне нужно внести?

Подробнее здесь: https://stackoverflow.com/questions/597 ... mer-method

Вернуться в «JAVA»