目前，我们为一个给定的主题创建了多个kafka消费者，该主题中的所有消息都由同一消费者组中的所有消费者共同处理。有可能吗？在每个kafka侦听器中，我们都可以指定使用者
浏览 5提问于2022-04-18得票数 0
回答已采纳
我有一个简单的，它从Kafka主题读取数据并将数据写入文件。这种方法的直接问题是，5个进程将写入同一个文件。我通过在文件名中附加一个唯一的进程id来解决这个问题。当我最终启动同一个程序的5个实例(JVM进程)时，我的期望是，如果运行在它自己的JVM进程中的一个使用者作业从分区读取
浏览 3提问于2020-09-19得票数 0
可以有多个属于同一消费者组的消费者同时从一个分区读取数据。是的，如果消费者来自不同的组，那么是的，多个消费者可以毫不费力地从同一分区读取数据。()。但我特别询问的是来自同一组的用户从同一分区读取数据。卡夫卡允许这样做吗？
浏览 14提问于2017-08-06得票数 1
一个消费者群体可以有一个或更多的消费者。来自消费者组的一个或多个使用者可以读取一个或多个分区。
消费者组的消费者应该从1分区中进行理想的消费。我试图理解在什么情况下，来自同一个使用者组的多个使用者从同一个分区读取信息是有意义的？
浏览 5提问于2022-11-06得票数 0
2回答
有人知道如何在Python中使用相同的组id运行多个消费者吗？我试着追随 'default.topic.config': {'auto.offset.reset': 'smallest'}})
b
浏览 0提问于2017-10-22得票数 0
2回答
对于同一主题，我们可以同时使用分区和消费者组吗？因此，我们希望创建一个具有分区的主题，然后为其创建多个消费者，其中2-3将是通用的，侦听所有消息(需要在消费者组中，以便消息不会被多次处理)，然后为特定分区创建一个消费者。
分区和消费者是互斥的吗？
浏览 1提问于2015-08-14得票数 0
默认情况下，多个Kafka消费者可以从同一个topic的同一分区中读取数据吗？默认情况下，我的意思是因为group.id不是强制性的，所以我想知道如果我在没有指定任何group.id的情况下产生多个kafka使用者，并为它们提供相同的主题和分区名称，它们是否能够从相同的分区中读取我知道，如果我为每个Kafka消费者提供不同的组名，那么所有消费者都可以从同一
浏览 4提问于2017-03-31得票数 1
如果您的使用者少于分区，这是否仅仅意味着您不会使用给定主题上的所有消息？
在云环境中，您应该如何跟踪有多少消费者正在运行，以及有多少消费者指向给定的topic#partition？如果给定的topic#partition上有多个消费者，该怎么办？
浏览 1提问于2016-12-01得票数 27
卡夫卡文件指出：
如果所有的使用者实例都有不同的使用者组，那么这就像发布-订阅一样，所有的消息都被广播给所有的使用者。我对此有几点怀疑：
1)为什么发布的消息将转到使用者组的单个使用者实例？从分区中读取不是消费者</e
浏览 4提问于2016-02-03得票数 1
回答已采纳
1回答
据我所知，每个分区只能有一个消费者(每个消费者组)，并且想要创建一个队列，我必须只使用一个消费者组，因为多个消费者组将获得相同的消息
问题:我有2个消费者，消费者处理的每个事件可能需要1分钟到30分钟，我创建了2个分区来在2个消费者之间分发事件。第一个分区获取2个事件，每个事
浏览 1提问于2020-12-13得票数 1
1回答
我是一个卡夫卡的初学者。我知道具有相同组id的多个消费者不能在一个主题中消费来自同一分区的消息。我想知道如果来自一个消费者组的多个Kafka消费者从一个分区读取相同的消息会发生什么，为什么这是一件坏事。
。
浏览 3提问于2021-10-17得票数 0
2回答
感谢所有答复：Question1:这两个消费者应该是同一个消费者群体吗？我想没有。因为它将导致一个使用者只从特定的分区获取消息。那么，请告诉我，在什么情况下，多个消费者被分组
浏览 4提问于2021-06-04得票数 1
1回答
因此，我有一个消费者组在运行并侦听来自某个主题的消息。如何将更多的消费者实例添加到消费组中？options, topicname);
//process message here ], groupId:
浏览 33提问于2020-10-07得票数 1
我们正计划编写一个Kafka消费者(Java)，它读取Kafka队列来执行消息中的操作。请帮我理解一下。
浏览 5提问于2016-02-23得票数 75
1回答
我有一个具有多个主题的Kafka-Broker，每个主题都有一个分区。我有一个消费者，它可以很好地使用主题中的消息 props.put("zookeeper.connect
浏览 25提问于2016-09-23得票数 4
回答已采纳
1回答
我试图让多个用户使用相同的groupId来处理卡夫卡主题的多个分区，这将帮助我扩展消息的消耗。将消费者作为同一个消费者组的一部分意味着提供来自主题分区的消息分布在组成员之间的“竞争消费者”模式。每个使用者从一个或多个分区(“自动”分配给它)接收消息，而其他使用者(分配给不同分区)不会接收相同的消息。通过这种方式，我们可以将消费者的数量扩展到<em
浏览 1提问于2019-10-14得票数 2
我知道来自一个主题的一条消息只能被一个组中的一个消费者消费，并且在一个消费者组中，每个消费者负责一个或多个分区。如果一个主题有4个分区，为了获取数据，我使用了env.addSource(FlinkKafkaConsumer).setParallism(4)，它实际上会创建4个消费者实例吗？如果不是，当4个消费者
浏览 22提问于2020-05-13得票数 0
回答已采纳
我有一个场景，用户做一些更新(例如添加新菜单)，这将转到nosql数据库(Mongo)。 我想使用Kafka，这样一个节点就会产生事件(添加到菜单中的新项目)，所有其他节点都会消费。在卡夫卡中，一个人如何充当生产者，其他人如何充当消费者？
浏览 29提问于2021-04-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
