我是卡夫卡的新手，有一个运行Kafka消费者的小程序，我正在使用卡夫卡工具向卡夫卡发布消息。当我在Windows7中配置设置时，我可以从kafka获取/读取消息，但它在windows10中不起作用。= new KafkaConsumer(config);
consumer.subscribe(Collections.singletonList("tnd_test_poc"));我在控制台输出中没有得到任何错误/警告/异常，
浏览 51提问于2020-10-06得票数 0
我打开一个控制台生产者在控制台中似乎可以工作，但是我在生产者中没有收到任何消息gid: trace= span= [kafka-producer-network-thread | producer-1] org.apache.kafka.clients.Metadata Cluster
浏览 9提问于2020-04-09得票数 1
回答已采纳
我看到了许多关于如何将日志发送到 Stackdriver的文档和帖子，但几乎没有关于如何进行相反操作的信息--将日志从发送到。在我的例子中，我们的操作程序希望使用Google的堆栈驱动程序代理从我们的web服务器收集日志，并将它们推到堆栈驱动程序中.但是，为了满足我的流处理需求，我想将日志输入Kafka，以便使用它无可比拟的能力来保留和重新处理任意数量的用户的数据我只看到了几条可能的路--听起来都不太好：
基于这篇文章：()首先将数据推入PubSub，然后使用卡夫卡连接器或编写自己的卡夫卡用户从中读取数据。没有多少细节
浏览 4提问于2021-05-05得票数 1
使用控制台时，我启动zookeeper、Kafka，然后启动consumer：bin/kafka-server-start.sh config/server.properties
bin/kafka-console-consumer.sh --bootstrap-server xxxxx
浏览 12提问于2017-06-06得票数 0
回答已采纳
在我下面的代码中，消费者订阅了现有的主题，但没有收到来自主题的消息，请帮助我，它会等待消息，而在kafka控制台中，消费者消息收到正常import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.a
浏览 0提问于2016-10-31得票数 1
1回答
我有几个Kafka用户订阅了一个主题，需要添加一些分区。我在临时环境中使用，并添加了一些新分区。我对Kafka的理解是，它们应该自动重新平衡，并订阅新的分区。除非他们不这样做，重启也没有用。每次我这样做(现在已经两次了)，一夜之间消费者就会订阅新分区。
如果我在控制台中创建一个新的测试组，它可以订阅新的分区。但在控制台中使用现有的组id进行订阅时，会重新平衡工作进
浏览 23提问于2019-07-05得票数 2
回答已采纳
我在K8s环境中运行Kafka，并有一个init容器来创建几个主题。我希望我的主容器只在主题创建并且主题是“可订阅的”时才启动。我确实尝试过kafka-控制台-使用者，但是即使主题不存在，它也不会退出状态1，如果无法访问引导服务器，它也会退出状态1。--timeout-ms 100kafka-console-consumer --bootstrap-server wrong-bootstrap-server:9092kafka</
浏览 1提问于2019-05-13得票数 2
回答已采纳
在此之后，我试图通过启动一个新的使用者(或终止一个)来重新平衡，并且在这个重新平衡中不能分配新的增加的分区。我发现，只有在停止所有使用者并启动它们之后，才能分配新的分区。以下是我在电脑上的测试：.1 --config retention.ms=6048000003.增加测试主题的两个分区
$ .4.启动一个
浏览 1提问于2018-10-17得票数 1
回答已采纳
2回答
我不面临任何问题，如果我运行任何生产者或消费者在一个终端，而另一个在春季启动。这个错误发生在无限循环中(当生产者和使用者都从不同的spring引导项目启动时)： at org.apache.kafka.clients.con
浏览 9提问于2021-03-29得票数 1
回答已采纳
我正在尝试运行正式的"Kafka010Example.scala"，但是它并没有像预期的那样从输入主题中读取和写入输出。我错过了什么或者做错了什么？任何帮助或暗示都很感激。我就是这样做的：
$ docker run -d -p 2181:2181 -p 9092:9092 spotify/kafka:latest
在容器中启动</
浏览 0提问于2017-10-14得票数 1
我尝试通过kafka-node npm库使用consumer和producer，以便通过nodejs使用kafka作为消息服务。我试着在kafka内置的生产者控制台中发送消息，但我的消费者似乎仍然不能成功订阅主题并获得消息。kafka-node'),consumer = kafka.Consumer;
const
浏览 56提问于2019-06-19得票数 3
我可以使用以下命令检索组：我可以为每个主题获取它们所连接的主题bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group TheFoundGroupId
浏览 9提问于2017-12-21得票数 4
6回答
/kafka-console-consumer.sh --zookeeper {localhost:port} --topic {topic_name} --from-beginning bootstrap_servers=['localhost:9092'],Message", message
浏览 1提问于2016-02-05得票数 12
我需要取消订阅卡夫卡主题与命令收到的休息。另外，我也需要通过REST订阅主题。我使用zio-kafka编写了以下代码来描述订阅主题并打印事件到控制台的效果：
val consumer: ZLayer[Clock with Blocking, Throwable, Has[Consumer]] =
浏览 1提问于2021-09-17得票数 0
回答已采纳
然而，在以务实的方式创建主题的同时，我也在为该特定主题的单独过程中开始(订阅)一个新的使用者。#Consumer code snippet
#Create topic #Initialize a consumer and subscribe to topic
Process(target=init_kafka</e
浏览 0提问于2019-04-08得票数 0
如何获取、设置或重置Kafka Connect连接器/任务/接收器的偏移量？我可以使用运行kafka.admin.ConsumerGroupCommand的/usr/bin/kafka-consumer-groups工具来查看我所有常规Kafka消费者组的偏移量。但是，Kafka Connect任务和组不会显示在此工具中。类似地，我可以使用zookeeper-shell连接到Zookeeper，我可以看到常规Ka
浏览 1提问于2016-06-09得票数 16
回答已采纳
我想构建一个使用Flask框架开发的python API，它使用Kafka主题并将流推送到客户端(html页面或其他应用程序)。consumer =
浏览 8提问于2016-12-02得票数 6
命令行上已启动的动物园管理员(所有命令都是从
kafka-console-producer.bat --broker-
浏览 2提问于2018-05-29得票数 1
回答已采纳
我正在使用docker通过以下命令运行一个kafka生产者advertised.listeners=PLAINTEXT://xxx.xx.x.x:9092
每当我使用以下命令从docker容器启动使用者时kafka-console-consumer
浏览 3提问于2019-03-20得票数 2
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
