我正在编写java api来创建kafka消费者，我有一个错误： Exception in thread "main" java.lang.NoSuchMethodError: org.apache.kafka.clients.consumer.Consumer.subscribeLjava/util/Collection;)V
at in.co.hadooptutorials.data.generator.cdr.kafkaconsumer.ma
浏览 6提问于2019-06-27得票数 2
回答已采纳
我已经在本地机器上设置了apache kafka，并且工作正常，当我将一条消息发布到生产者中时，它立即在消费者提示中流动。
可以从我的本地文件夹配置连续文件流吗？我该怎么做呢？我可以编写一个java应用程序来配置我的生产者吗？
浏览 0提问于2016-07-28得票数 0
我们最近开始使用Kafka，我正在使用Kafka Java原生消费者API编写一个Kafka消费者应用程序。 });
}
我只是在寻找一种更
浏览 0提问于2019-06-05得票数 0
如何使用直播流API指定kafka spark流的消费组id。
浏览 0提问于2016-04-09得票数 7
回答已采纳
我希望实现一个从Kafka主题消费的函数，对于每个消费的消息，它调用另一个方法对消息进行一些处理，然后将其存储在数据库中。源kafka主题有12个分区。我想在同一个消费群体下创建6到12个kafka消费者。所有的消费者都将消费来自Kafka的消息并调用该函数。我不能得到一个好的设计。有人能帮帮我吗？
浏览 1提问于2020-02-19得票数 1
我正在尝试编写一些简单的生成器，将消息写入kafka，我已经下载了kafka0.7> bin/kafka-server-start.sh config/server.properties然后我已经创建了简单的消费者，它也是有效的。: kafka.message.Message cannot be cast to
浏览 0提问于2013-06-20得票数 1
回答已采纳
但是当我尝试使用新的消费者API时，我遇到了一些问题。我完成这项工作的步骤如下：<dependency> <artifactId>kafka-clientsStringDeserializer.class.getName());
config.put(ConsumerConf
浏览 2提问于2015-06-16得票数 17
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。我们需要Java 1.7 / 1.8来使用Stream API吗？
浏览 3提问于2018-12-20得票数 0
我对kafka ACL配置有点困惑，在kafka ACL配置中，我们为生产者和消费者配置授权。有各种使用命令行生成/消费消息的示例。我们是否需要任何额外的配置来使用JAVA api向/从安全的kafka主题生成/消费消息。
浏览 2提问于2016-06-15得票数 0
2回答
Kafka Rest示例
、、、
有没有使用Java中的Kafka rest api的生产者和消费者组的好例子。我不是在寻找生产者和消费者的简单消费者或卡夫卡客户端的例子。任何帮助都会被接受。
浏览 2提问于2016-08-17得票数 3
回答已采纳
有一个应用程序(不是我的)从Kafka读取消息，对它们进行一些处理，并将记录存储在数据库中。我用Java编写了一个程序，它以给定的速率将消息写入队列。现在，它通过在测试运行结束时查询数据库来进行简单的性能测量，以确保记录in = records out。但是，我想将其扩展为定期检查队列，以查看应用程序尚未处理的挂起消息的数量，以及是否正在备份它。我想我可以在Zookeeper中检查应用程序组ID的偏移量。我查看了，但它只给出了基本<e
浏览 2提问于2015-07-23得票数 3
2回答
我有一种情况(不要问)，我有需要从外部服务提交给Kafka的偏移量信息(主题、分区、偏移量)。唯一的方法是创建一个KafkaConsumer对象并调用commitSync / commitAsync吗？或者，有没有一种我错过的机制，我可以在不实例化KafkaConsumer的情况下进行提交？
浏览 0提问于2018-10-31得票数 2
1回答
我正在使用kafka 0.10 kafkaConsumer接口来获取消费者和消费者订阅下的主题集。我的问题是如何获得组和主题之间的关系。我引用<em
浏览 0提问于2016-12-06得票数 2
Kafka 0.8官方文件对Kafka消费者的描述如下：
“使用者用使用者组名称给自己贴上标签，发布给主题的每一条消息都被传递给每个订阅的使用者组内的一个使用者实例。使用者实例可以在单独的进程中或在不同的机器上。如果所有的使用者实例都有相同的使用者组，那么这就像对消费者的传统队列平衡负载一样。”。我用Kafka 0.8.1.1设置了Kafka集群
浏览 1提问于2015-11-26得票数 0
有没有人知道是否可以将writeStream调用到Kafka主题，其中创建的主题是压缩主题？下面的代码创建了一个Kafka主题，但是传递的选项被忽略了。StreamingQuery query = ds .format("kafka")
.option("kafka.bootstrap.servers", "localhost:9092&
浏览 0提问于2019-03-18得票数 2
1回答
我正在寻找kafka来实现一个低延迟的消息队列，并且我一直在阅读关于消费者长轮询的文章。但是，没有关于如何实际使用长轮询的示例，或者需要设置哪些选项才能启用它。如何使用kafka java api启用长轮询？
浏览 0提问于2013-10-25得票数 12
回答已采纳
Apache Beam和Apache Kafka在流处理方面有什么不同？我也在努力掌握技术和编程上的差异。
请通过您的经验报告来帮助我理解。
浏览 1提问于2018-06-15得票数 10
我是卡夫卡流的新手。我想知道使用kafka流API而不是使用标准kafka生产者/消费者API和用Java在消费者中进行流处理会带来什么好处。
浏览 4提问于2022-04-25得票数 0
回答已采纳
1回答
我正在尝试使用golang在Go中创建一个kafka流客户端。据我所见，这只有在使用Java客户机时才有可能。我做了一些搜索，并找到了其他一些第三方图书馆，但没有正式的。另外，根据我有限的理解，我认为流是语法糖而不是标准消费者吗？这是对的吗？
浏览 4提问于2021-12-13得票数 1
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
