下面是我的卡夫卡消费者public class Consumer {
spring.kafka.groupId=Product-Group
我的卡夫卡消费者是自动开始的。但是，我希望禁用自动启动的KAFKA使用者，而不必对现有代码进行任何更改，包括根据需求在使用者类中设置autoStartup = "{xyz}"。我正在寻找一个现有的
浏览 1提问于2021-02-10得票数 0
回答已采纳
我有使用spring.cloud.stream.kafka.binder.brokers=KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes=ZKNODE_URL的消费者
如果我尝试运行spring boot消费者应用程序，但bean未启动，则整个spring boot应用程序无法启动: rg.springframework.context.ApplicationContextException:<em
浏览 4提问于2017-03-21得票数 0
我们有3个代理节点的Kafka集群。当所有的都启动并运行时，消费者能够从Kafka读取数据。然而，如果我停止了所有的Kafka服务器，并且只启动了2个Kafka服务器，除了最后一个停止的服务器，那么消费者就无法连接到Kafka集群。这背后的原因可能是什么？提前谢谢。
浏览 37提问于2020-11-27得票数 0
我有一个使用kafka streams的spring boot应用程序(kafka docker镜像：wurstmeister/kafka:2.12-2.1.1，kafka依赖：org.apache.kafka在应用程序启动期间，我检查是否创建了主题my-topic，如果没有- application创建了它。当新版本的应用程序准备就绪时，k8s会启动新应用程序并缩小旧应用程序的规模。在kafka文档中，1个分区只能由1个消费者</e
浏览 1提问于2020-05-22得票数 0
2回答
我有一个控制台应用程序，它有多个BackgroundServices，每个都使用Confluent.Kafka nuget包(v1.6.2)读取相同的Kafka主题。该主题有3个分区。当应用程序启动时，所有的后台服务都会调用它们的构造函数，但是只有一个ExecuteAsync方法会被调用。代码如下：using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hostin
浏览 25提问于2021-02-26得票数 1
回答已采纳
我的kafka经理无法更新消费者信息并保留已删除的消费者组列表，因此我尝试重新启动kafka-manager。(我用的是卡夫卡经理1.3.3.22和kafka 2.12-2.1.1)
但是卡夫卡管理器和/bin/kafka管理器命令中的README.md似乎没有提供停止/重新启动。
浏览 6提问于2020-05-29得票数 3
回答已采纳
1回答
我有一个具有多个主题的Kafka-Broker，每个主题都有一个分区。我有一个消费者，它可以很好地使用主题中的消息import kafka.consumer.Consumer;import
浏览 25提问于2016-09-23得票数 4
回答已采纳
1回答
我已经使用python.How创建了实现的Kafka生产者-消费者消息传递主题我可以对队列做同样的事情，这样消息就只会发送给一个消费者。这是我的生产者代码from kafka import KafkaProducer
print("Me
浏览 3提问于2020-12-03得票数 0
1回答
我正致力于为银行创建一个大容量的JSON数据处理应用程序，使用Spring、Kafka和QuickFIX/J。这是我第一次使用Kafka和QuickFIX/J这样的技术，无法决定是使用普通的Kafka spring还是Kafka流还是spring云流。以下是要求：
从多个进程读取数据，并将数据发送给QuickFIX/J启动器，后者进一步将其发送到外部修复引擎-- QuickFIX/J受体从外部修复引擎接收数据，并将其再次写入<em
浏览 7提问于2020-06-01得票数 0
我正在尝试用多个生产者和多个消费者来测试我的Kafka集群。我遇到了很多可用的工具和文章，但是所有这些工具和文章都是从一台机器生成负载(生产者)，并类似地从一台机器读取(使用者)。我正在寻找一个工具，它可以跨/生成多个生产者和使用者，并对给定的kafka集群进行负载测试。
作为投入，我们可以给出生产者和消费者的数量。然后，它可以与生产商和消费者(在AWS、Azure或GCP上)生成这些数量的机器。或者，我们可以手动生成机器，然后工具可以<
浏览 15提问于2022-02-09得票数 -1
回答已采纳
我使用Ubuntu服务器16.04来尝试使用Kafka。对于启动生产者和消费者控制台的命令，我使用以下命令。生产者控制台：消费者控制台：
bin/kafka-console-consumer.sh如何订阅多个主题？
浏览 1提问于2017-01-02得票数 12
我有一个带有多个分区的kafka主题。
我想将主题转储到一个文件中来进行一些分析，因此我认为最简单的方法就是使用kafka-控制台用户。我的问题是，kafka-控制台-使用者是否能够读取所有主题分区，还是将其分配给单个分区？如果不是，如何将kafka-控制台-消费者分配到特定的分区，因此一个将不得不启动与分区一样多的kafka-控制台-消费者。
浏览 4提问于2015-08-27得票数 0
回答已采纳
2回答
我想知道是否有可能读取和处理多个消息由Kafka消费者(Java客户端)并行..I意味着使用多线程...我应该使用rxJava吗?？3)并希望使Java客户端作为守护服务运行在Linux中，这样它就可以连续运行，轮询Kafka
浏览 0提问于2016-02-24得票数 0
这是我的消费者代码： props.put("group.id", "testgroup"); con
浏览 0提问于2016-04-03得票数 0
我有多个微服务(spring boot)，其中一些通过kafka消息与其他微服务通信。当我想在服务1上测试kafka消费者时(检查kafka是否可以接收来自其他服务的消息)，我需要启动服务1的docker，然后启动服务2的docker，然后调试到服务2，并进行一些更改以进行测试。是否可以在不启动服务2的情况下将kafka发送到服务1(在docker上运行)？怎么能做到呢。谢谢
浏览 1提问于2018-10-10得票数 1
我们使用了3个群id相同的kafka消费者来读取数据。--replication-factor 5和--partitions 5的Kafka主题这里的任何帮助都将不胜感激。
浏览 0提问于2018-03-26得票数 0
当kafka代理启动并运行时，在集群模式下运行的spark进程能够读取来自kafka主题的消息。但是当代理被故意关闭时，spark消费者仍然处于运行状态。是否有任何参数来控制spark消费者和zookeeper进程之间的握手间隔，以便如果无法访问代理，spark进程可能会失败。或者有没有让消费者失望的替代方法。请提个建议。
浏览 0提问于2021-02-18得票数 0
1回答
我试图让多个用户使用相同的groupId来处理卡夫卡主题的多个分区，这将帮助我扩展消息的消耗。将消费者作为同一个消费者组的一部分意味着提供来自主题分区的消息分布在组成员之间的“竞争消费者”模式。通过这种方式，我们可以将消费者的数量扩展到分区的数量(让一个消费者只读取一个分区)；
java.lang.IllegalStateException(DirectKafkaIn
浏览 1提问于2019-10-14得票数 2
1回答
它从kafka读取数据，处理数据，然后将其写入MSSQL。
kafka主题已经被划分为10个分区--两年之后，团队正在考虑增加分区的数量，因为集群显示出不再管理卷的迹象。我的消费者已经实现为windows服务，其中每个服务启动一个kafka消费者。我们已经安装了10个服务，以便每个服务处理一个分区。当主题增加时，我应该能够安装和启动一些额外的消费者，一切都应该顺利进行。我开始怀疑是否不应该改变设计，让单个服务启动多个
浏览 0提问于2021-11-18得票数 0
回答已采纳
有多个代码示例可用(其中之一是)，其中实现了KafkaProducer和KafkaConsumers，并且可以单独启动。props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, IKafkaConstants.KAFKA_BROKERS);
这是不是意味着KafkaProducer自己启动了代理？
浏览 3提问于2018-08-03得票数 2
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
