0

我相信作为生产者属性的 3 种类型的确认仅限于领导者和生产者，我希望生产者在消费者通过 kafka 代理消费来自存储/队列的消息时接收到具体消息。如果我对生产者的“ acks ”属性有误，也请纠正我，它的默认值为“-1”，它确认所有副本是否都已接收/存储消息，但它与消费者有什么关系，或者可以当消费者提交并且kafka向生产者发送确认时，我们创建了一个桥梁？

4

1 回答 1

0

Consumer 和 Producer 是独立的组件，在 Kafka API 中两者之间没有开箱即用的确认框架；你必须自己实现这个

您对 acks 的理解是正确的，但无法控制消费者行为，当消息可用时，消费者行为总是从领导分区读取

于 2021-02-09T15:10:46.000 回答