如何在kafka rest proxy中设置生产者和消费者？如果我使用kafka-clients.jar并用java实现它，我可以轻松地进行所有设置。acks、commit方法等。我知道可以在confluent-4.1.1/etc/kafka rest中设置基础知识。
确认、如何提交等。如何配置？
参考文献：https://docs.confluent.io/current/kafka-rest/docs/config.html
如何在kafka rest proxy中设置生产者和消费者？如果我使用kafka-clients.jar并用java实现它，我可以轻松地进行所有设置。acks、commit方法等。我知道可以在confluent-4.1.1/etc/kafka rest中设置基础知识。
确认、如何提交等。如何配置？
参考文献：https://docs.confluent.io/current/kafka-rest/docs/config.html
1条答案
按热度按时间lxkprmvk1#
提交是通过发布从以前的消费请求中获得的补偿来完成的。
POST /consumers/(string: group_name)/instances/(string: instance)/offsets提交使用者的偏移列表。当post主体为空时，它将提交使用者示例获取的所有记录。我不认为可以通过http请求设置ACK
生产者示例是共享的，因此不能基于每个请求设置配置。但是，您可以通过在rest代理配置中传递新的生产者设置来全局调整设置