我有如下的kafka制作人： import json producer = KafkaProducer(obj)
File "C:\Program Files (x86)\Microsoft Visual Studio\Shared\Python36_64\lib\json\encoder.py",(x86)\Microsoft Visual Studio\Shared\<em
浏览 112提问于2021-06-27得票数 0
我最近尝试使用python向Kafka发送消息。当使用简单的字节消息时，它可以工作。但是现在，我有了一个json数据，我需要将其发送到Kafka主题，然后Java应用程序将使用它。我试图找出如何将json转换为byteArray (这是Java应用程序期望的有效负载)。所以，我想出了下面的python脚本。只有我修复了这个错误，
浏览 95提问于2018-07-21得票数 0
使用循环调用kakfa produce类时，无法将消息写入kafka topic (producer)。 我对Python和Kafka非常陌生。我正在尝试编写一个python程序，将消息写入Kafka主题并生成，以便Kafka消费者可以订阅该主题以发布消息。 我不确定我的程序中缺少了什么，它限制了向主题写入消息。注意:我正在读取一个JSO
浏览 36提问于2019-01-12得票数 0
我的目标是从非文件来源(即在程序中生成或通过API发送)获取数据，并将其发送到spark流。为此，我通过 KafkaProducer发送数据$ bin/kafka-server-start.sh1 --partitions 1 --topic my-topicPython</em
浏览 14提问于2017-07-09得票数 0
回答已采纳
如何使用kafka-console-producer在kafka topic中插入json文件数据？每个json数据集可以存储为一条消息吗？last_name": "Lindt", "gender": "Male",
"ip_address": "
浏览 2提问于2019-02-13得票数 11
1回答
我在windows中运行Kafka。我正在用下面的命令创建一个Kafka控制台生产者 C:\kafka_2.11-2.4.0\bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic input-topic 并使用以下命令创建kafka控制台消费者 C:\kafka_2.11-2.4.0\bin\windows>kafka
浏览 8提问于2020-09-23得票数 0
我创建了一个生产者和一个消费者，使用“Kafka节点”包发送和消费来自kafka主题的信息。生产者和消费者通过API调用。POST方法用于向主题发送消息，而GET方法用于在使用者处从主题获取消息。当我在向KAFKA发送消息之后调用消费API时，所有以前的消息都在consumer.on('message', function(m
浏览 6提问于2021-12-15得票数 0
我正在尝试制作一个Producer来向JHipster发送消息。我在他们的网站上提出了一个简单的例子：
from kafka import KafkaProducer
#
浏览 2提问于2017-11-15得票数 0
回答已采纳
我使用Kafka 2.12和kafka-python模块作为Kafka客户端。producer.send('topic', json.dumps(message).encode('utf-8'))如果我刷新生产者并更改linger_msproducer.send('topic', json.du
浏览 15提问于2017-07-14得票数 3
5回答
我很好奇你应该如何表达你想要在faust中传递一条消息给Kafka主题。class Greeting(faust.Record): to_name: str
topic = app.topic('hello-topic', valu
浏览 0提问于2019-06-27得票数 11
我试图使用kafka console-producer发布一条包含的消息，其中包括、键(带模式)和值(带有模式)。不幸的是，我找不到一个做我想做的事情的例子。我可以跟踪文档并发送简单的消息： --broker-list localhost:9092 \
--topic some-topictype" : "strin
浏览 7提问于2021-10-04得票数 0
回答已采纳
topic test这是一条消息2016-08-24 18:15:27,441向topic test发送消息时出错: null，value: 2字节错误:包含1条记录的(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException:批次在向broker请求测试元数据时超时
浏览 13提问于2016-08-24得票数 0
1回答
我正在使用python kafka生成器来编写一个主题。Kafka服务器是外部的，我使用Kerberos连接凭据。ssl_cafile="truststore.pem",ssl_keyfile='truststore.jks',sasl_mechanism='GSSAPI',api_version=(0, 10, 1))# Write hello w
浏览 36提问于2020-03-14得票数 0
我有一个独特的身份在我的数据，我发送给卡夫卡与卡夫卡-python图书馆。当我向kafka主题发送samne数据时，它无论如何都会消耗相同的数据。有没有办法让卡夫卡跳过以前的消息，从新消息中跳过连络。def consume_from_kafka(): TOPIC,
bootstrap_servers=["localh
浏览 11提问于2022-04-01得票数 0
我正在尝试使用Apache Flink 1.11创建一个源表，在这里我可以访问JSON消息中的嵌套属性。我可以从根属性中提取值，但我不确定如何访问嵌套对象。, properties MAP 'connector' = 'kafka-0.11',
'topic' = &#x
浏览 124提问于2020-09-23得票数 1
回答已采纳
我想确保一个不同的应用程序发布正确的信息给kafka。因此，这在某种程度上介于集成和单元测试之间，因为我只想测试生产者将正确的内容放入kafka中。有效的测试是：
但是，也许有一些测
浏览 3提问于2017-06-06得票数 4
这里有一个python opcua client。datachange_notification(self, node, val, data)将作为python opcua client的一部分执行，每当client到达新数据时，请参见下面的脚本，是否可以将到达的数据(在这个上下文中是val)发送到kafka-client。= 0:
浏览 1提问于2020-02-19得票数 0
回答已采纳
我在一个应用程序中使用kafka-python (pip install kafka-python)向Kafka集群发送消息(运行0.11版)。但是，我没有看到任何消息到达Kafka (通过控制台用户验证了这一点)。
除了如何连接到正在运行的集装箱外，我对码头不太了解。所以我就是这么做的。我登录到豆茎实例，然后连接到码头容器。我第一次使用pip安装kafk
浏览 0提问于2018-02-15得票数 0
有没有办法删除队列消息而不删除Kafka主题？我知道有几种方法：
重置保留时间$ ./bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic MyTopic --config retention.ms=1000删除卡夫卡文件$ rm -rf /data/kafka-logs/<topic
浏览 5提问于2017-09-14得票数 39
回答已采纳
(可能是的翻版，尽管这个问题的OP没有提到kafka。无论如何，它一直没有得到答案。)我有一个Python程序，它已经成功地(很多个月了)向Kafka broker发送消息，实际上使用了以下逻辑：最近，我试图升级它，根据从消息中提取的一个明确的键值将<em
浏览 3提问于2017-08-02得票数 4
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
