我开始学习Kafka用于企业解决方案.
在我的阅读中,我想到了一些问题:
每个消费者组在代理上是否有相应的分区,或者每个消费者都有一个分区?
作为经纪人创建的分区,因此不关心消费者?
由于这是一个每个分区都有一个偏移量的队列,因此消费者有责任指定它想要读取哪些消息吗?是否需要保存其状态?
从队列中删除邮件时会发生什么? - 例如:保留时间为3小时,然后时间过去了,两侧的偏移量如何处理?
apache-kafka kafka-consumer-api kafka-producer-api
apache-kafka ×1
kafka-consumer-api ×1
kafka-producer-api ×1