腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(6433)
视频
沙龙
1
回答
使用
C#
向
生产者
发送
消息
时
,如
何在
kafka
消息
中
添加
头部
属性
?
c#
、
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
maximumMessageBuffer); var fileStream = new FileStream(@"D:/
kafka
_examples); client.SendMessageAsync("Hello-
Kafka
", new[]
浏览 43
提问于2020-04-13
得票数 1
1
回答
在
kafka
producer
中
启用COMPRESSION_TYPE_CONFIG "gzip“后,我无法在消费者端看到数据压缩
java
、
apache-kafka
、
kafka-producer-api
我想用
kafka
压缩
消息
。因此,我在
生产者
端启用了压缩类型为gzip,并且没有在server.propeties上做任何更改。config.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "gzip"); 这是我在
生产者
配置
中
添加
的代码,但当我
向
主题
发送
消息
时
,当我在消费者端读取
消息
时
,
消息
并未压缩。有没
浏览 85
提问于2020-11-23
得票数 0
1
回答
如
何在
Spring Boot
中
设置
Kafka
幂等生成器?
java
、
spring
、
spring-boot
、
apache-kafka
、
idempotent
我们希望
使用
exactly-once语义将数据存储在
Kafka
中
,以避免
消息
重复。具有以下
属性
的生成器: spring.
kafka
.producer.properties.acks=all kafkaTemp
浏览 86
提问于2021-07-27
得票数 1
回答已采纳
2
回答
Kafka
多线程发布到同一分区
apache-kafka
、
spring-kafka
我有数千条记录要在一个事务中发布到同一分区上的
Kafka
。我正在
使用
spring KafkaTemplate来做这件事。为了提高我当前逻辑的性能,我正在考虑在多线程中进行
Kafka
发布。
使用
多线程会导致多个线程之间的偏移量冲突吗?我应该坚持
使用
一个线程来完成所有的发布吗?
浏览 34
提问于2018-08-03
得票数 0
1
回答
当卡夫卡服务器和制片之间的连接中断
时
,信息会发生什么变化?
java
、
spring-boot
、
apache-kafka
我是卡夫卡中
使用
spring引导的新手,我在projet
中
工作,我希望将卡夫卡
使用
spring集成到其中,所以问题是我想从
生产者
那里
向
消费者
发送
消息
,即使卡夫卡服务器不运行(离线模式)。有人能给我举一个例子,说明在离线模式下如何
使用
kafka
,我找不到这个主题的tuto --我想停止我的
kafka
服务器(例如),同时
生产者
想要
发送
数据到主题,那么消费者就可以得到这些
消息</
浏览 0
提问于2019-02-25
得票数 2
回答已采纳
1
回答
Spring Cloud Stream
Kafka
:如
何在
向
kafka
主题生成
消息
后访问
kafka
头部
的recordMetadata
spring-cloud-stream-binder-kafka
我想在
向
kafka
topic发出
消息
后,获取偏移量和分区信息。我通读了spring cloud stream
kafka
绑定文档,发现这可以通过
使用
RECORD_METADATA
kafka
头来实现。
发送
到通道的
消息
是具有附加标头KafkaHeaders.RECORD_METADATA的已
发送
消息
(转换后,如果有)。
头部
包含一个由
Kafka
客户端提供的RecordMetadata
浏览 0
提问于2020-09-23
得票数 1
1
回答
出现错误时如何重试
kafka
消息
-- spring云流
spring
、
apache-kafka
、
stream
我正在
使用
spring cloud stream
Kafka
来生产和消费 public void process(Order order) {
浏览 1
提问于2020-05-13
得票数 0
2
回答
ActiveMQ:
使用
者/
生产者
为同一个队列实现不同的协议?
java
、
node.js
、
jms
、
activemq
我最近进入了
消息
队列(
使用
ActiveMQ)并进行了实验。 是否有可能让
生产者<
浏览 0
提问于2014-01-16
得票数 0
1
回答
卡夫卡JMX
中
的
消息
当前速率
java
、
apache-kafka
、
jmx
、
prometheus
我已经以jmx_prometheus_javaagent作为java代理在本地启动了
Kafka
实例。为了尝试我的设置,我
浏览 2
提问于2017-04-28
得票数 3
回答已采纳
2
回答
Kafka
producer在broker关闭
时
丢失
消息
java
、
apache-kafka
、
kafka-producer-api
假设有以下场景: 我在本地启动zookeeper和一个
kafka
代理,并创建“测试”主题,
如
kafka
快速入门:中所述。然后,我运行一个简单的java程序,该程序每秒生成一条指向"test“主题的
消息
。一段时间后,我关闭了我的本地
kafka
代理,看到producer继续生成
消息
,它没有抛出任何异常。最后,我再次启动
kafka
broker,producer能够重新连接到broker,并继续生成
消息
,但是,在
kafka
bro
浏览 1
提问于2018-04-06
得票数 1
2
回答
用SpringBoot测试SpringBoot @sendTo
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
、
kafka-producer-api
我正在
使用
@SendTo("example")注释
向
主题
发送
消息
,但我不知道如何测试它。我打开一个控制台
生产者
在控制台中似乎可以工作,但是我在
生产者
中
没有收到任何
消息
gid: trace= span= [
kafka
-producer-ne
浏览 9
提问于2020-04-09
得票数 1
回答已采纳
3
回答
卡克法重试概念-卡夫卡将停止什么基础重试?
apache-kafka
、
kafka-producer-api
、
producer-consumer
现在来问一下,
浏览 11
提问于2020-05-04
得票数 0
1
回答
Spring @StreamListener条件不推荐替代方案
java
、
spring-boot
、
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我们让多个应用程序
使用
者收听相同的
kafka
主题,并且
生产者
在
向
主题
发送
消息
时
设置
消息
头,以便特定实例能够评估标头并处理
消息
。log.info("sydney order request received message is {}",message.getName());在SpringCloudStream3.0.0
中
,@StreamListener被废弃了,我无法在函数中找到与条件<em
浏览 11
提问于2021-09-16
得票数 5
2
回答
生成UUID以响应
Kafka
生产者
发送
的
消息
c
、
apache-kafka
、
producer
我正在尝试开发一个应用程序,它从缓存
中
读取字节数组(表示一个C结构,每个数组与一个UUID相关联),并通过C语言的
生产者
应用程序将其
发送
到
Kafka
Server。
kafka
生产者
应用程序累积固定数量的此类数据包,并立即
发送
它们。 我希望完成的工作是确认批处理
中
的哪些
消息
已成功传递,并取回它们的UUID,以便我可以从缓存应用程序
中
清除它们。
浏览 9
提问于2018-06-06
得票数 0
1
回答
kafka
自定义分区和重新分区
apache-kafka
、
partitioning
、
kafka-topic
我们可以为
kafka
主题指定自定义分割器。因此,
kafka
生产者
可以根据特定的自定义算法将
消息
确定地
发送
到特定的分区。 现在的问题是,当我增加分区数量
时
,
kafka
将如
何在
新分区之间重新分配现有
消息
?或者
Kafka
不会将
消息
分发到新分区?有可能触发这种重新分配吗?如果是这样,那么
kafka
将如何了解自定义分区程序,因为这段代码驻留在
生产者
部分?
浏览 6
提问于2020-09-15
得票数 1
2
回答
在卡卡
生产者
中
配置重试的最佳方法
apache-kafka
、
kafka-producer-api
将同步副本配置为Acks=all和min.insync.replicas = N,当
Kafka
无法处理ISR
时
,在线记录在处理过程
中
是N-1,最小配置的
浏览 8
提问于2021-01-17
得票数 0
1
回答
使用
Kafka
-avro-控制台-
生产者
连接MongoDB接收器连接器
mongodb
、
apache-kafka
、
avro
、
apache-kafka-connect
我试图
使用
Kafka
连接MongoDB连接器
向
MongoDB编写一些文档。我成功地设置了所需的所有组件并启动了连接器,但是当我
使用
Kafka
-avro-控制台-
生产者
向
Kafka
发送
消息
时
,
Kafka
connector给了我以下错误: org.apache.
kafka
.connect.errors.DataException我尝试将这个字段
添加</em
浏览 7
提问于2022-09-02
得票数 0
1
回答
用sarama编写
Kafka
制片人时的无效时间戳
go
、
apache-kafka
、
apache-kafka-streams
、
sarama
我有一个
Kafka
实例正在运行(在本地,在一个Docker
中
),我
使用
在Go
中
创建了一个
生产者
。由于我想在我的主题中
使用
Kafka
流,所以
生产者
必须在
消息
中
嵌入一个时间戳,否则我会得到一条丑陋的错误
消息
: org.apache.
kafka
.streams.errors.StreamsException可能是因为在没有嵌入时间戳的情况下,
使用
了预0.10
生
浏览 0
提问于2018-10-08
得票数 4
回答已采纳
1
回答
弹簧云卡夫卡绑定查询
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我们有一个需求,当我们
使用
来自一个主题的
消息
时
,会有一些充实发生,然后我们将
消息
发布到另一个主题。我正在
使用
活页夹,一切都很好。突然,我们观察到
生产者
正在
向
主题
发送
重复的信息,然后我们使
生产者
是幂等的。为了更好的控制,我们让autocommitOffSet做错了。enrichMessage = // Enrichment on inputMessage} 我们观
浏览 3
提问于2021-09-28
得票数 0
1
回答
对于不同的主题,最好
使用
单独的
kafka
模板/
使用
相同的
kafka
模板。
java
、
spring
、
apache-kafka
、
kafka-producer-api
我的应用程序需要将不同的记录
发送
到不同的主题。我的应用程序正在
使用
同样的
Kafka
集群。由于应用程序
使用
相同的
Kafka
集群,创建一个
生产者
工厂就足够了(如果需要更多的话,请告诉我)。对两个主题
使用
相同的kafkaTemplate,并按以下主题调用send方法(请假定我
使用
了春季默认的
Kafka
生产者
配置)。在这里,我们需要为每个调用传递主题&对于多个主题,我们
使用
相同的
Kafka<
浏览 10
提问于2022-09-05
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka之文件消费者应用案例
4.kafka生产者&消费者
Kafka详细的设计和生态系统
Kafak的吞吐量为何这么高呢?
消息队列中间件(三)Kafka 入门指南
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
云直播
实时音视频
活动推荐
运营活动
广告
关闭
领券