如何在Kafka REST代理中配置生产者和消费者？

Question

我如何在Kafka REST代理中建立一个生产者和消费者？如果我使用kafka-clients.jar并在java中实现它，我可以轻松地进行所有设置。acks，提交方法，等等。我知道，基础可以设置在汇合-4.1.1/ etc / kafka-rest。

如何提交，等等，如何配置？

参考资料：https://docs.confluent.io/current/kafka-rest/docs/config.html

Answer 1

背诵是由POSTing完成的，这是您从以前的消费请求中得到的补偿。

POST /consumers/(string: group_name)/instances/(string: instance)/offsets 为使用者提交一个补偿列表。当post主体为空时，它将提交由使用者实例获取的所有记录。

我不认为HTTP请求可以设置ack

生产者实例是共享的，因此不能根据每个请求设置信任。但是，可以通过在REST代理配置中传递新的生产者设置来全局调整设置。