腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9961)
视频
沙龙
1
回答
使用
Kafka
Producer
中
的
布尔
变量
(
此处
已
发送
)
向
方法
调用
发送
确认
java
、
apache-kafka
我正在实现一个sendStringMessage
方法
,如果消息被
发送
到主题,该
方法
将返回true。但我得到了错误(如代码中所示),定义在封闭作用域中
的
局部
变量
发送
必须是最终
的
或有效
的
最终
的
。或者,我们是否可以创建一个自定义回调函数,在消息
发送
到主题时返回一个
布尔
值。defined in an enclosing scope must be final or effectively final
浏览 10
提问于2021-07-27
得票数 0
回答已采纳
2
回答
kafka
有异步请求/响应java api吗?
apache-kafka
我们更喜欢在生产者上
使用
异步请求/响应 public void response(ResponseIf success, ack the upstream
kafka
}我唯一看到
的
是将
producer
.type设置为asynch,但
调用
只是一个异步请求,没有等待任何响应…… <e
浏览 0
提问于2014-03-08
得票数 7
1
回答
如何在Spring Boot
中
设置
Kafka
幂等生成器?
java
、
spring
、
spring-boot
、
apache-kafka
、
idempotent
我们希望
使用
exactly-once语义将数据存储在
Kafka
中
,以避免消息重复。具有以下属性
的
生成器: spring.
kafka
.
producer
.properties.acks=all
浏览 86
提问于2021-07-27
得票数 1
回答已采纳
1
回答
可靠消息传递
apache-kafka
、
kafka-producer-api
我
使用
Kafka
客户端0.9.0.0
向
Kafka
集群
发送
消息。该系统是一种管道,它消耗来自JMS
的
消息并将其
发送
给
Kafka
。为了确保消息
的
可靠性,JMS应答模式被设置为CLIENT_ACKNOWLEDGE,以便当消息被
使用
和成功处理时,应用程序
确认
消息接收。我可以
使用
Kafka
生
浏览 1
提问于2016-09-19
得票数 0
回答已采纳
1
回答
Spring :非事务性生产者回调处理
spring-kafka
我正在
使用
一个非事务性生产者,并试图了解在成功/失败场景
中
如何处理回调。然后,我通过
向
kafka
模板提供一个不存在
的
主题名来模拟一个失败,这次似乎在侦听器容器线程
中
执行回调(“未
浏览 7
提问于2020-03-15
得票数 0
回答已采纳
1
回答
Python生产者可以通过shell
发送
,但不能通过.py
发送
。
python
、
python-3.x
、
apache-kafka
、
kafka-python
我有一个运行并经过测试
的
Kafka
集群,并且正在尝试
使用
Python脚本
向
代理
发送
消息。当我
使用
Python3 shell并
调用
producer
方法
时,这是可行
的
,但是当我将这些相同
的
命令放入Python3并执行它时--脚本似乎挂起了。当我
使用
Python3 shell时,我可以看到
使用
Kafka
工具2.0.4出现在主题中
的
消息
浏览 0
提问于2019-04-05
得票数 1
回答已采纳
1
回答
弹簧云卡夫卡绑定查询
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我们有一个需求,当我们
使用
来自一个主题
的
消息时,会有一些充实发生,然后我们将消息发布到另一个主题。下面是一些事件我正在
使用
活页夹,一切都很好。突然,我们观察到生产者正在
向
主题
发送
重复
的
信息,然后我们使生产者是幂等
的
。为了更好
的
控制,我们让autocommitOffSet做错
浏览 3
提问于2021-09-28
得票数 0
1
回答
KeyError:
kafka
.
producer
.record_accumulator.RecordBatch
python
、
asynchronous
、
apache-kafka
、
send
、
keyerror
使用
kafka
-python
向
主题
发送
大量消息。成功地将部分消息
发送
到主题,但并非所有消息都是在程序以下列错误消息终止之前
发送
的
:在我
的
主题中,每次运行都会收到不同数量
的
消息。问题似乎是,卡夫卡
produce
浏览 0
提问于2017-10-10
得票数 1
1
回答
Kafka
topic未收到发布者send()
的
某些记录
java
、
apache-kafka
、
kafka-producer-api
Java应用程序
向
Kafka
集群
发送
或发布消息。
发送
记录
的
代码如下所示。由于这个应用程序
向
kafka
发送
了大量
的
记录消息,因此调试起来有点困难。但我看到一些消息没有
发送
给
kafka
,因为我在
kafka
broker subscriber
中
没有看到相同主题
的
一些消息。所以看起来这条管道中有一些数据泄漏。为此,我添加了java.util.concur
浏览 29
提问于2019-09-20
得票数 0
2
回答
如何
使用
Kafka
节点从
kafka
主题中删除消息
node.js
、
apache-kafka
、
kafka-node
我创建了一个生产者和一个消费者,
使用
“
Kafka
节点”包
发送
和消费来自
kafka
主题
的
信息。生产者和消费者通过API
调用
。POST
方法
用于
向
主题
发送
消息,而GET
方法
用于在
使用
者处从主题获取消息。当我在
向
KAFKA
发送
消息之后
调用
消费API时,所有以前
的
消息都在consumer.on('message
浏览 6
提问于2021-12-15
得票数 0
1
回答
使用
多线程将多条消息同时发布到
Kafka
patitions进行测试,检查性能
java
、
multithreading
、
apache-kafka
、
avro
org.apache.avro.generic.GenericData; import org.apache.
kafka
.clients.
producer
.KafkaProducer; import org.apache.
kafka
.clients.
produce
浏览 0
提问于2020-05-08
得票数 0
3
回答
Kafka
2.9.2-0.8.1.1无KeyedMessage参数用于
producer
.send
java
、
apache-kafka
我正在用java
向
Kafka
发送
一个信息。我
的
项目通过maven依赖项
使用
kafka
_2.9.2-0.8.1.1.jar: <groupId>org.apache.
kafka
</groupId> <artifactId我想
发送
一个KeyedMessage,并通过这里
的
文档:,它声明
producer
.send
方法
应该
浏览 6
提问于2015-01-06
得票数 2
回答已采纳
1
回答
将星火结构流API和DStream混合写入
Kafka
apache-spark
、
spark-streaming
、
spark-structured-streaming
") )我得到了错误 val df = spark .format("
kafka
&qu
浏览 1
提问于2020-07-13
得票数 3
回答已采纳
7
回答
Kafka
Producer
错误,主题:XXXXXX: 6686 ms
的
10条记录过期,从批量创建到延迟时间已过
apache-kafka
Kafka
版本: 0.10.2.1,org.apache.
kafka
.common.errors.TimeoutException: Expiring 10 record(
浏览 6
提问于2017-10-15
得票数 29
1
回答
Spring :保存到数据库后,我想将数据
发送
给
kafka
spring-webflux
、
spring-data-mongodb-reactive
在我
的
数据库操作成功后,我正在尝试
向
kafka
发送
数据。不知道该怎么做。public Mono<?Mono<StockDTO> stoc
浏览 6
提问于2022-06-06
得票数 0
1
回答
Spring Cloud Stream
Kafka
:如何在
向
kafka
主题生成消息后访问
kafka
头部
的
recordMetadata
spring-cloud-stream-binder-kafka
我想在
向
kafka
topic发出消息后,获取偏移量和分区信息。我通读了spring cloud stream
kafka
绑定文档,发现这可以通过
使用
RECORD_METADATA
kafka
头来实现。来自Spring文档:() recordMetadataChannel成功
发送
结果应
发送
到
的
MessageChannel
的
bean名称;该bean必须存在于应用程序上下文中。
发送
到通道
的
消息是具有附加
浏览 0
提问于2020-09-23
得票数 1
1
回答
Kafka
错误处理: Processor.output().send(message,kafkaTimeoutInMS)总是返回true及其异步
error-handling
、
apache-kafka
、
messaging
、
spring-cloud-stream
可能这个问题已经被报告和解决了,.I没有找到解决方案和任何与此相关
的
开放问题,所以创建一个新
的
问题。我正在尝试处理
向
kafka
主题发布数据时出现
的
错误。有了
kafka
spring steam,我们就可以用这个来推动
kafka
}
浏览 1
提问于2018-10-12
得票数 1
1
回答
无法将消息
发送
到端口转发
的
Kafka
pod
kubernetes
、
apache-kafka
、
kafka-consumer-api
、
portforwarding
我正在玩一个卡夫卡吊舱( incubator/
kafka
图表),我运行在一个kubernetes集群
中
,试图
发送
和接收一些测试数据。localhost:9092 \我能够
使用
以下
方法
成功地向
使用
者
发送
数据: -n
kafka
-namespace\ --
kafka
-console-
producer
浏览 12
提问于2022-07-27
得票数 0
回答已采纳
1
回答
Kafka
模板和
kafka
producer
有什么区别?
java
、
spring-boot
、
apache-kafka
、
spring-kafka
、
kafka-producer-api
正如我所看到
的
,
Kafka
模板内部
使用
了
Kafka
生成器。我只想知道到底有什么不同。此外,我发现与
Kafka
producer
相比,
Kafka
模板中提供了许多send()
方法
。 请帮我拿一下。
浏览 1
提问于2020-09-09
得票数 1
2
回答
Kafka
生产者在
kafka
服务器宕机时无限期
发送
阻塞
apache-kafka
、
kafka-producer-api
我
使用
的
是
Kafka
0.11.0.0。我有一个发布到
Kafka
主题
的
测试程序;如果zookeeper和
Kafka
服务器关闭(这在我
的
开发环境
中
是正常
的
;我会根据需要启动它们),那么对KafkaProducer<>.send()
的
调用
就会无限期地挂起我需要让send()返回,最好是指示错误;或者我需要一种
方法
来检查服务器是启动还是关闭。基本上,我希望我
的</em
浏览 3
提问于2017-11-18
得票数 7
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
聊聊 Kafka:Producer 源码解析
Kafka解惑之Old Producer(1)——Beginning
Kafak的吞吐量为何这么高呢?
Kafka-Clients源码学习:KafkaProducer篇
深入Kafka系列(一)Producer开发
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券