什么是kafka消费者组？
答：消费者组的概念是Apache Kafka独有的。基本上，每个Kafka消费群体都由一个或多个共同消费一组订阅主题的消费者组成。
-
我对Kafka比较陌生。我对它做了一些实验，但有一些东西对我来说是不清楚的关于消费者抵消。根据我到目前为止的理解，当使用者启动时，它将从其开始读取的偏移量由配置设置确定（如果我错了，请更正）。 现在举个例子，在主题中有10条消息（偏移0到9)，一个消费者碰巧在它关闭之前（或者在我杀死消费者之前）消费了其中的5条消息。然后假设我重新启动消费者进程。我的问题是： > 如果设置为，是否总是从偏移量0开始
-
我刚接触Kafka，很少阅读教程。我无法理解使用者和分区之间的关系。 请回答我下面的问题。 > 消费者是否由ZK分配到单个分区，如果是，如果生产者将消息发送到不同的分区，那么其他分区的消费者将如何使用该消息？ 我有一个主题，它有3个分区。我发布消息，它会转到P0。我有5个消费者（不同的消费者群体）。所有消费者都会阅读P0的信息吗？若我增加了许多消费者，他们会从相同的P0中阅读信息吗？如果所有消费者
-
Flink kafka消费者有两种类型的消费者，例如： 这两个消费者层次结构扩展了相同的类。我想知道维护编号类背后的设计决策是什么？我们什么时候应该使用其中一种？ 我注意到带有数字后缀的类有更多的特性（例如ratelimiting）。 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka
-
本文向大家介绍消费者和消费者组有什么关系？相关面试题，主要包含被问及消费者和消费者组有什么关系？时的应答技巧和注意事项，需要的朋友参考一下 每个消费者从属于消费组。具体关系如下：
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
本文向大家介绍什么是消费者或用户？相关面试题，主要包含被问及什么是消费者或用户？时的应答技巧和注意事项，需要的朋友参考一下 答：Kafka消费者订阅一个主题，并读取和处理来自该主题的消息。此外，有了消费者组的名字，消费者就给自己贴上了标签。换句话说，在每个订阅使用者组中，发布到主题的每个记录都传递到一个使用者实例。确保使用者实例可能位于单独的进程或单独的计算机上。 Apache Kafka对于新手