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

Question

如何在 Kafka REST Proxy 中设置生产者和消费者？如果我使用 kafka-clients.jar 并在 java 中实现它，我可以轻松进行所有设置。acks、提交方法等。我知道基础可以在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

提交消费者的偏移量列表。当 post body 为空时，它会提交消费者实例获取的所有记录。

我不认为 Acks 可以通过 HTTP 请求设置

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