腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
kafka
没有
producer
发送
的
消息
java
、
apache-kafka
、
apache-zookeeper
、
spring-kafka
、
kafka-producer-api
我使用spring框架和
kafka
,它有3个代理集群。我发现消费者
没有
消费一些
消息
(假设所有
发送
的
消息
之间有0.01%),所以在生产者代码中,我记录了api返回
的
消息
偏移量: ListenableFuture<SendResult<String, MessagesendResult = future.get(); String offset = sendResult.getRecordMetadata().offset(); 我使用retu
浏览 15
提问于2019-05-16
得票数 2
回答已采纳
2
回答
无法向
Kafka
Python中
的
Topic
发送
消息
python
、
apache-kafka
、
kafka-python
我有一个生产者代码,在那里我
发送
消息
给卡夫卡。
没有
任何失败或错误
消息
,代码可以执行,但不会
发送
消息
。
kafka
-python==2.0.1下面是我
的
代码,import logging logging.basicConfigINFO:
kafka
.
producer
.
kafka
:Closing
浏览 3
提问于2020-06-16
得票数 0
1
回答
Spring :非事务性生产者回调处理
spring-kafka
为了
发送
成功,我看到回调由
kafka
生产者-网络线程(“已
发送
确定”
消息
)执行。(“未能
发送
”
消息
),然后是侦听器容器线程中
的
“已
发送
”
消息
!容器线程是如何记录“未能
发送
”
消息
的
--这是回调
的
一部分!在记录失败
消息
之后,它会记录
发送
的
消息
(卡夫卡模板中
的
doSend方法<em
浏览 7
提问于2020-03-15
得票数 0
回答已采纳
1
回答
将
消息
从AWS Lambda推送到
Kafka
node.js
、
apache-kafka
、
aws-lambda
我有一台运行在AWS中
的
kafka
机器,它由几个主题组成。我有下面的Lambda函数,它生成一条
消息
,并将其推送到其中一个
kafka
主题。import json from
kafka
import SimpleProducer from
kafka
import KafkaProducer
producer
= SimpleProducer(
kafka
, async = Tru
浏览 12
提问于2019-07-19
得票数 6
回答已采纳
1
回答
无法向卡夫卡主题
发送
信息
scala
、
apache-kafka
我用
的
是卡夫卡,玩得和斯卡拉一样好。这是我
的
代码,我想在这里
发送
消息
给卡夫卡服务器,主题名是“test-”。我
没有
收到任何错误,虽然我还
没有
在主题中看到我
发送
的
消息
,这里有什么问题吗?import
kafka
.
producer
.ProducerConfig import
kafka
.
producer</
浏览 3
提问于2016-04-13
得票数 2
回答已采纳
2
回答
无法看到星火中卡夫卡流
的
信息
apache-spark
、
pyspark
、
apache-kafka
、
spark-streaming
、
twitter-streaming-api
我刚刚开始使用
Kafka
Stream库对Spark进行测试。import jsonfrom uuid import uuid4from
kafka
import KafkaConsumer__init__() print tweet #
Kafka
<
浏览 4
提问于2017-09-30
得票数 0
2
回答
Kafka
produce.send从不
发送
消息
python
、
apache-kafka
、
kafka-python
producer
.send('topic', json.dumps(message).encode('utf-8'))如果我刷新生产者并更改linger_ms参数(使其同步),
消息
将由消费者
发送
和读取:daemon = True
producer
= KafkaProducer
producer
.s
浏览 15
提问于2017-07-14
得票数 3
1
回答
异步生成
消息
时
的
ProducerClosed错误
python-asyncio
、
python-3.7
我正在使用aiokafka异步生成
消息
。我有一个使用django
的
Api,它正在向
kafka
队列生成
消息
。一切都很顺利。现在,当我将相同
的
api转换为使用aiohttp服务器时,就会出现以下错误: )response =
浏览 5
提问于2019-10-14
得票数 1
回答已采纳
1
回答
Kafka
Python使用者使用auto_偏移量_重置=‘最早’,但不使用auto_偏移量_重置=‘最新’
kafka-python
我读过很多文章和卡夫卡
的
官方文件,但在这里我想不出这个问题。如果不工作,我
的
意思是在for循环中放置一个断点,并使用生产者
发送
消息
:任何帮助都是非常感谢
的<
浏览 7
提问于2020-05-05
得票数 1
1
回答
KeyError:
kafka
.
producer
.record_accumulator.RecordBatch
python
、
asynchronous
、
apache-kafka
、
send
、
keyerror
使用
kafka
-python向主题
发送
大量
消息
。成功地将部分
消息
发送
到主题,但并非所有
消息
都是在程序以下列错误
消息
终止之前
发送
的
:在我
的
主题中,每次运行都会收到不同数量
的
消
浏览 0
提问于2017-10-10
得票数 1
1
回答
同步卡夫卡制作人
发送
还有0秒超时吗?
python
、
apache-kafka
我在Python脚本中有以下代码
kafka
_
producer
.flush() 然而,我仍然看到了下面的
消息
。<em
浏览 6
提问于2020-11-06
得票数 1
5
回答
BrokerNotAvailableError:在Spark Streaming时找不到leader异常
apache-kafka
我
的
主题是"test“,它是由以下命令创建
的
:NodeJS中
的
生产者:var
Producer
=
kafka
.
Produ
浏览 1
提问于2015-07-23
得票数 13
1
回答
使用者在运行生产者和使用者python脚本时
没有
显示任何
消息
。
apache-kafka
、
ubuntu-16.04
、
kafka-python
我在Ubuntu服务器上设置了Apache,并按照中提到
的
前五个步骤进行了测试,一切都很顺利。侦听器=明文://localhost:9092这是剧本from
kafka
consumer = KafkaConsumer('m
浏览 0
提问于2019-06-18
得票数 1
回答已采纳
1
回答
Python生产者可以通过shell
发送
,但不能通过.py
发送
。
python
、
python-3.x
、
apache-kafka
、
kafka-python
我有一个运行并经过测试
的
Kafka
集群,并且正在尝试使用Python脚本向代理
发送
消息
。当我使用Python3 shell并调用
producer
方法时,这是可行
的
,但是当我将这些相同
的
命令放入Python3并执行它时--脚本似乎挂起了。当我使用Python3 shell时,我可以看到使用
Kafka
工具2.0.4出现在主题中
的
消息
--我在python代码中尝试过各种循环和语句,但似乎
没有
什么能使它“运
浏览 0
提问于2019-04-05
得票数 1
回答已采纳
1
回答
java 1.6上
的
Kafka
出厂错误
java
、
apache-kafka
、
kafka-producer-api
我试图在java 1.6上运行
kafka
producer
,我使用
的
是0.8.1.1版本。它正在运行,但是当它试图
发送
消息
时,它给出了 Exception in thread "Main"
kafka
.common.FailedToSendMessageException: Failed toat
kafka
.
producer
.async.DefaultEventHandler.handle(DefaultEventHandler.
浏览 5
提问于2016-02-07
得票数 0
回答已采纳
2
回答
如何使用
Kafka
节点从
kafka
主题中删除
消息
node.js
、
apache-kafka
、
kafka-node
我创建了一个生产者和一个消费者,使用“
Kafka
节点”包
发送
和消费来自
kafka
主题
的
信息。生产者和消费者通过API调用。POST方法用于向主题
发送
消息
,而GET方法用于在使用者处从主题获取
消息
。当我在向
KAFKA
发送
消息
之后调用消费API时,所有以前
的
消息
都在consumer.on('message', function(message){})中得到了安慰。=
浏览 6
提问于2021-12-15
得票数 0
1
回答
Kafka
topic未收到发布者send()
的
某些记录
java
、
apache-kafka
、
kafka-producer-api
Java应用程序向
Kafka
集群
发送
或发布
消息
。
发送
记录
的
代码如下所示。由于这个应用程序向
kafka
发送
了大量
的
记录
消息
,因此调试起来有点困难。但我看到一些
消息
没有
发送
给
kafka
,因为我在
kafka
broker subscriber中
没有
看到相同主题
的
一些
消息
。所以看起来这条管道中有一些数
浏览 29
提问于2019-09-20
得票数 0
2
回答
Kafka
: java客户端在x次尝试后未能
发送
消息
java
、
apache-kafka
我试图从Java应用程序向
Kafka
发送
消息
。我所能得到
的
只有“两次尝试后未能
发送
消息
”:
浏览 3
提问于2015-06-16
得票数 3
回答已采纳
9
回答
如何使用
Kafka
(超过15 How )
发送
大型
消息
?
java
、
apache-kafka
我用Java生产者API向
Kafka
V.0.8
发送
字符串
消息
。如果
消息
大小约为15 MB,我将得到一个MessageSizeTooLargeException。小
消息
没有
问题。我能做些什么来摆脱这个异常呢?我
的
示例生产者配置 Properties props = new Properties();
浏览 14
提问于2014-01-09
得票数 163
回答已采纳
1
回答
producer
.poll(0)不会产生任何
消息
,但
producer
.flush()可以工作
python
、
apache-kafka
、
confluent-platform
根据
kafka
confluent issue
的
说法,当我使用
producer
.flush()时,它可以工作,但性能很差,但正如我建议
的
那样,我使用
producer
.poll(0),但不会向主题生成任何
消息
self.
producer
.produce(topic.value, data.encode('utf-8'), callback=self.delivery_report) self.
producer
.poll(0) #
浏览 248
提问于2019-12-04
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka是批量发送消息的?
关于Kafka producer管理TCP连接的讨论
简单的Kafka:没有ZooKeeper的Kafka
go使用kafka对网页浏览数据进行统计
kafka之producer
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券