Как настроить производителя и потребителя в Kafka REST Proxy?

Question

Как настроить производителя и потребителя в Kafka REST Proxy? Если я использую kafka-clients.jar и внедряю его в java, я легко могу сделать все настройки. acks, метод commit и так далее. Я знаю, что основы могут быть установлены в confluent-4.1.1 / etc / kafka-rest.

acks, как сделать коммит и т. Д. Как мне это настроить?

Рекомендации: https://docs.confluent.io/current/kafka-rest/docs/config.html

Answer 1

Фиксация выполняется путем отправки смещений, полученных вами из предыдущего запроса на потребление.

POST /consumers/(string: group_name)/instances/(string: instance)/offsets

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

Я не думаю, что acks может быть установлен HTTP-запросом

Экземпляры источника являются общими, поэтому конфигурации нельзя устанавливать для каждого запроса. Однако вы можете изменить настройки глобально, передав новые настройки производителя в конфигурации REST Proxy