消费者有没有办法向使用 kafka(kafka.js) 和 node.js 实现的生产者发送确认？
Is there any way for a Consumer to send an acknowledgement to a producer implemented using kafka(kafka.js) and node.js?
我相信 3 种类型的确认，因为生产者属性仅限于领导者和生产者，我希望生产者在消费者通过 kafka 代理消费来自 storage/queue 的消息时收到具体消息.
如果我在生产者的“acks”属性 上有误，请纠正我，它的默认值为“-1”，它确认是否所有副本都具有 received/stored消息，但是它与消费者有什么关系，或者我们可以在消费者提交并且kafka向生产者发送确认时创建一个桥梁吗？
Consumer和Producer是孤立的组件，Kafka中两者之间没有开箱即用的确认框架API；你必须自己实现这个
你对 acks 的理解是正确的，但无法控制消费者行为，消费者行为总是在消息可用时从 leader 分区读取
我相信 3 种类型的确认，因为生产者属性仅限于领导者和生产者，我希望生产者在消费者通过 kafka 代理消费来自 storage/queue 的消息时收到具体消息. 如果我在生产者的“acks”属性 上有误，请纠正我，它的默认值为“-1”，它确认是否所有副本都具有 received/stored消息，但是它与消费者有什么关系，或者我们可以在消费者提交并且kafka向生产者发送确认时创建一个桥梁吗？
Consumer和Producer是孤立的组件，Kafka中两者之间没有开箱即用的确认框架API；你必须自己实现这个
你对 acks 的理解是正确的，但无法控制消费者行为，消费者行为总是在消息可用时从 leader 分区读取