我正在使用下面的生产者API代码将消息写入Kafka topic，但它无法将消息写入topic：import com.typesafe.config.ConfigFactoryimport org.apache.kafka.clients.producer.")
浏览 33提问于2019-03-31得票数 0
我正在写一批作业来重播卡夫卡的事件。Kafka诉0.10.1.0和火花1.6。我试图使用JavaPairRDD javaPairRDD =KafkaUtils.createRDD(.)打电话： org.apache.kafka.clients.producer.Producer producer = new Kaf
浏览 4提问于2016-12-15得票数 0
我把Kafka客户端生产者写成： public static void main(String[] args){props.put("batch.size","16384");// maximum size of message
System.
浏览 0提问于2018-09-12得票数 2
如何使用kafka-console-producer在kafka topic中插入json文件数据？每个json数据集可以存储为一条消息吗？-
cat sampledata.json|kafka-console-producer --broker-list localhost:9092 --topic stream-test-topic每一行都作为单独的
浏览 2提问于2019-02-13得票数 11
2回答
我正在尝试用设置一个简单的Kafka应用程序。我一直在尝试让我在网上找到的一些例子起作用，但似乎无法做到。我有一个运行在docker容器中的kafka实例。我测试了shell工具，实例确实工作正常。我能够发送和接收消息。我怀疑生产者消息超时了。下面是代码的两个版本，它们的行为基本相同：
imp
浏览 21提问于2017-07-09得票数 3
我正在开发一个Spring引导应用程序。该应用程序充当Kafka-producer，其中生产/发布消息并不是很重要。我的应用程序显示以下日志 17:18:45.187 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient} 日志处
浏览 245提问于2021-08-12得票数 1
13回答
在用kafka生成消息时，我得到了以下错误：hello
[2016-07-19 17:06:34,542] ERROR Error when sending message to topic nil_PF1_P1 with key: null, value: 2 bytes with error
浏览 18提问于2016-07-19得票数 36
回答已采纳
我的主题是"test“，它是由以下命令创建的：NodeJS中的生产者：var Producer
浏览 1提问于2015-07-23得票数 13
到目前为止，我还没有看到一个python客户端可以显式地实现主题的创建，而不使用配置选项自动创建主题。
浏览 1提问于2014-09-25得票数 40
我试图理解'compression.type‘配置，我的问题是，如果我在主题级别和生产者级别设置'compression.type’，那么哪个优先？
浏览 4提问于2020-01-24得票数 8
回答已采纳
我创建了一个生产者和一个消费者，使用“Kafka节点”包发送和消费来自kafka主题的信息。生产者和消费者通过API调用。POST方法用于向主题发送消息，而GET方法用于在使用者处从主题获取消息。当我在向KAFKA发送消息之后调用消费API时，所有以前的消息都在consumer.on('message', function(m
浏览 6提问于2021-12-15得票数 0
6回答
针对同一主题为使用者运行命令行工具时，我确实看到带有--from-beginning选项的消息，否则它将挂起如果我通过python运行它，它会挂起，我怀疑这是由不正确的使用者配置引起的</
浏览 1提问于2016-02-05得票数 12
我是一个新的kafka空间，我在Kubernetes中安装了Strimzi集群运算符、Kafka引导服务器、实体操作符和kafka connect，遵循以下准则：
大多数论坛都对融合的卡夫卡进行了解释，但没有对卡夫卡进行解释。下面是我的<
浏览 16提问于2022-09-22得票数 0
我已经为所有Hadoop服务启用了Ambari v2.7.3和HDP v3.1.0中的Kerberos。我已经使用NIFI验证了HBase身份验证。我也需要测试卡夫卡。在卡夫卡控制台，我可以创造一个主题。但是在生产和消费过程中，我面临着一个错误，如下所示。security-protocol is not a recognized option
浏览 0提问于2019-07-09得票数 0
回答已采纳
1回答
: zookeeper:2181 - /var/run/docker.sock:/var/run/docker.sock~/kafka_2.11-1.0.0$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test>[2018-01-19: (org.
浏览 0提问于2018-01-19得票数 1
使用循环调用kakfa produce类时，无法将消息写入kafka topic (producer)。 我对Python和Kafka非常陌生。我正在尝试编写一个python程序，将消息写入Kafka主题并生成，以便Kafka消费者可以订阅该主题以发布消息。 我不确定我<em
浏览 36提问于2019-01-12得票数 0
1回答
电火花流写卡夫卡主题
、、、
当使用以下代码向kafka发布消息时，我对性能有问题。下面是我在代码中编写的代码。我已经检查了日志，我只能在纱线日志文件中找到以下信息。producer.KafkaProducer:用timeoutMillis = 9223372036854775807 ms关闭卡夫卡制作人
你能告诉我我错过了什么吗。火花版本为<
浏览 0提问于2019-02-19得票数 2
我写了一个kafka的消费者和生产者，直到今天都工作得很好。今天早上，当我启动zookeeper和kafka时，我的消费者无法读取消息，我在zookeeper日志中发现了以下内容：
INFO Got user-level KeeperException when
浏览 61提问于2015-12-21得票数 48
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
