这不是一个大问题，但我很好奇，一些额外的流消费者来自哪里，如果这是一个设置，我可以改变。}
不过，当我运行这个应用程序时，我可以看到在输出中创建了3个消费者。但是，当我检查本地代理中的消费者组成员时，它总是一个
浏览 7提问于2021-04-14得票数 0
回答已采纳
1回答
根据Kafka的文件，它说：java.lang.IllegalStateException: Previously t
浏览 1提问于2019-10-14得票数 2
我想知道如何在从executor进程内部运行的SimpleConsumer之间共享Kafka分区。我知道高水平的Kafka消费者是如何在消费者群体中的不同消费者之间分享部分的。但是，当Spark使用简单的消费者时，这是如何发生的呢？将有多个执行器用于跨机器的流式作业。
浏览 0提问于2018-05-18得票数 0
我做过一些Kafka流应用程序和Kafka消费者应用程序。归根结底，Kafka流只是消费者，它消费来自Kafka的实时事件。所以我不知道什么时候使用Kafka streams，或者为什么我们应该使用Kafka streams，因为我们可以在消费者端执行所有的转换。我想了解Kafka stream和Kafka consumer之间的主要区别，以及如何在不同的用例中决
浏览 4提问于2019-12-04得票数 4
据我所知：
(可能是基于意见的)如何处理在单个分区上操作的单独组的两个使用者之间的
浏览 0提问于2017-07-18得票数 12
回答已采纳
我更改了我的网络服务的消费者组id，听了卡夫卡的主题。现在，旧的组id仍然注册到主题中，但是没有使用该组id的使用者。因此，它是滞后的。如何从特定主题中删除特定的使用者组？我试过这个：但是它返回：“使用者不支持特定主题的从使用者组中删除偏移量。”我
浏览 2提问于2020-09-02得票数 10
回答已采纳
为什么不推荐使用kafka-consumer中的zookeeper，为什么建议使用bootstrap服务器？bootstrap-server有什么优点？
浏览 0提问于2017-09-12得票数 36
回答已采纳
每个服务都有自己的Kafka主题和该主题的消费者组。如果我们在同一组中添加另一个服务，它是否会影响其他3个服务，因为它们也共享相同的ConsumerGroup名称，尽管它们绑定到不同的主题？或者，如果一个新的消费者被添加到Service3中，那么Kafka需要重新平衡主题分区的使用者吗？它是否会影响其他主题，因为它们共享使用者组名称？我认为消费者群体是与主题联系在一起的，即使其他主题的消费者有相同的消费群体名称，它也不应该影响。
浏览 8提问于2022-08-05得票数 0
1回答
我想知道有没有最好的方法/实践来从消费者/生产者那里查找kafka broker，这样当应用程序从一个环境(如Dev)转移到其他环境(如ST、UAT、Prod)时，我们就不需要更改消费者/生产者代码。目前，所有示例都显示消费者/生产者需要知道集群中kafka broker的IP地址和端口号。
提前感谢您的建议和意见。
浏览 10提问于2017-06-29得票数 0
reconnect.backoff.ms = 50ssl.keystore.type = JKS
线程"main“中的异常:未能在org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:624) at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:518)
浏览 5提问于2016-07-15得票数 24
回答已采纳
我正在创建两个apache camel (blueprint XML) kafka项目，一个是kafka-producer，它接受请求并将其存储在kafka服务器中，另一个是kafka-consumer，它从kafka服务器获取消息并处理它们。但是，如何在同一个kafka topic中创建独立的消费群？如何在不同消费者组内的同一主题内路由多个特定于消费者的消息？如有任何帮助，我们将
浏览 28提问于2020-05-03得票数 1
我已经开始我的生产者发送数据到Kafka，也开始我的消费者拉相同的data.When，我正在使用消费卡夫卡处理器(kafka版本1.0)在Apache Nifi，我在我的脑海中有几个问题，与Kafka消费者相关Q.2)还有在Kafka中消费者关机的情况下，如何在最后一条消费消息之后阅读消息？
我们如何在使用Apache Nifi的同时实现上述两个功能？
浏览 20提问于2018-07-30得票数 2
回答已采纳
如何在Kafka上获取连接消费者的列表？作为消费者连接在代理上，是否有像ZkClient/ZkUtils这样的java实用工具在Kafka 0.9.0.x中获得连接消费者的列表？,brokerId); zkClient.close();我正在使用Kafka 0.9.0.x，下面是maven中的java lib：
浏览 1提问于2016-10-17得票数 4
回答已采纳
3回答
我正在尝试实现一个简单的排队系统，使用1个主题和分配给该主题的1个消费者组。然而，我不知道如何创建一个消费者组。谢谢!埃里克
浏览 1提问于2013-02-25得票数 1
apache kafka的新版本在内部存储消费者组数据，而不是使用zookeeper你能告诉我：
如何在使用新的消费者API时删除属于主题T的消费者组C
浏览 6提问于2017-11-10得票数 0
在我们的事务处理系统中实现了kafka流处理。该解决方案实现如下：
Kafka producer将事件发布到kafka topic，流处理器处理输入事件并进行聚合操作。由于第一个topic中没有实现消费者，如何从第一个topic中移除已处理的消息。
浏览 0提问于2017-08-14得票数 1
1回答
我的一个主要用例是解决基于特定id的消息/事件排序(就像Kafka世界中的partition key )。在这种情况下，当发布到Kafka主题时，我将使用order-id作为分区键。如何在Jetstream中完成此操作？我在Jetstream中遇到了去重键(Nats-Msg-Id)，但我认为这个功能与Kafka中的主题压缩更有同义词。我说的对吗？在Jetstream世界中，特定orderId的所有订单是否都会到达同一
浏览 216提问于2021-08-30得票数 5
当我作为消费者连接时，其中一个代理成为组协调器。然后我杀了一个经纪人(否则它就死了)。如果我尝试立即重新连接到代理，则会出现协调程序不可用错误。Kafka是如何知道经纪人死了的，需要多长时间才能指派一个新的协调员？它是如何配置的？
这本应在文档中，但我找不到。
浏览 2提问于2017-08-08得票数 3
云服务器
ICP备案
对象存储
云直播
腾讯会议
腾讯云开发者
