腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
如何
使用
KafkaTemplate
设置
消息
头
?
、
、
、
我正在构建一个Spring Boot 2.4.4应用程序,
使用
模式验证向Kafka (Confluent Platform)生成
消息
。该模式是在该主题的模式注册表中
设置
的,我已经
使用
Maven Avro插件从相关的AVSC文件创建了POJO (LoanInitiate)。@Autowired @Value("${kafka.topic}"
浏览 293
提问于2021-04-23
得票数 1
1
回答
如何
从kstream应用中读取Kafka
消息
头
、
、
可以从kstream应用读取我在kafkaProducer应用中
设置
的Kafka
消息
头
吗?我的KafkaProducer看起来像这样;我已经在
消息
中
设置
了
头
public class Producer {public Producer(
KafkaTemplate
浏览 6
提问于2020-07-17
得票数 1
1
回答
Spring Kafka @SendTo不发送标
头
、
、
、
我用ReplyingKafkaTemplate向卡夫卡发送了一条
消息
,它用kafka_correlationId发送
消息
。
如何
保存卡夫卡标题?由此,另一件奇怪的事情是,ReplyingKafkaTemplate没有向
消息
中添加文档中的kafka_replyTopic
头
。下面是
如何
配置ReplyingKafkaTemplate:public KafkaMessageListenerContainer<Object, Object> replyContainer,s
浏览 0
提问于2019-04-10
得票数 0
回答已采纳
1
回答
@SentTo
如何
将
消息
发送到相关主题?
、
、
、
我在Rest控制器中
使用
ReplyingKafkaTemplate来返回同步响应。我也在
设置
头
REPLY_TOPIC。request.setReply(resp); return request; } 我的问题是,@sentTo注解
如何
将
消息
发布到标题中提供的主题应该有一个
KafkaTemplate
bean,还是它不需要它?因为我们只是返回
消息
,而
浏览 30
提问于2019-06-01
得票数 1
1
回答
Kafka中发送ProducerRecord所需的串行器类型
、
我
使用
spring kafka (
KafkaTemplate
)来发送字符串
消息
。但是为了使它与旧代码兼容,我需要在
消息
中附加额外的CorrelationId。所以我创建了ProducerRecord对象,将我的
消息
作为它的值,并在它的HeaderRecord中
设置
CorrelationId。_.sendDefault(producerRecord); 键和值序列化程序被
设置
为StringSerializer,但是about代码失败,说明ProduderRecord不是S
浏览 6
提问于2017-12-12
得票数 0
回答已采纳
1
回答
基于条件的EnrichHeader
、
我正在编写一个通用适配器,从EMS获取
消息
,并推送到Kafka主题。如果配置文件中的某个特定标志
设置
为true,则我必须丰富标
头
。标
头
的表达式也将存在于配置文件中 return IntegrationFlows.from(org.springframework.integration.jms.dsl.Jms .messageDrivenChannelAdapterh.headerExpression(KafkaHeaders.MESSAGE_KEY, "headers['flightNb
浏览 7
提问于2020-04-07
得票数 0
2
回答
Spring
消息
反序列化失败,因为内容类型被
设置
为application/json。
、
、
我向卡夫卡传达如下信息: } 这在反序列化错误中失败,在调试之后,我看到原因是
消息
的内容类型标
头
被
设置
为application/json,因此它试图将
消息
反序列化为JSON。内容类型标
头
是
如何
设置
的
浏览 0
提问于2019-07-15
得票数 1
回答已采纳
1
回答
当
消息
被重试时,spring的投递尝试没有增加。
我
使用
Spring-Kafka2.8.6和重试RetryTopicConfiguration。 topics = "...@Header(KafkaHeaders.DELIVERY_ATTEMPT) final int deliveryAttempt) {我已经
设置
了常见的错误处理程序,还启用了传递尝试标
头
。factory.getContainerProperties().setDeliveryAttemptHeader(true); return fa
浏览 24
提问于2022-07-05
得票数 2
回答已采纳
1
回答
如何
在
使用
Spring非阻塞重试向DLT发送
消息
时添加自定义标
头
?
、
、
、
我在中
使用
SpringKafka2.8.0。我
使用
固定退避和死信主题的单一重试主题。这是我的配置:public RetryTopicConfiguration receiptRetryConfiguration(}@Bean(RetryTopicInternalBeanNames.DEAD_LETTER_PUBLISHING_RECOVERER_
浏览 18
提问于2022-03-07
得票数 0
2
回答
Spring消费者标题中缺少关于__TypeId__的信息
、
、
、
我正在探索Spring (spring-boot-starter-parent版本2.7.4),我在消费者中发现了一些奇怪的行为,并
使用
了标准的@KafkaListener注释。我用
KafkaTemplate
生成
消息
并添加自定义的报头支柱__ProducerApp__,但是我也有标准的标
头
支柱__TypeId__,因为它是由Spring实现自动添加的。<String, KafkaPayload>
kafkaTemplate
; public KafkaExampleProducer(<
浏览 17
提问于2022-10-08
得票数 0
2
回答
为多个实体配置ReplyingKafkaTemplate
、
、
、
、
命名为“客户端”和“服务器”由于一些限制,我必须
使用
同步请求-回复模式与kafka。所以我尝试
使用
ReplyingKafkaTemplate。我的问题是我需要
使用
多个实体。因此,在我的代码中,我创建了多个KafkaConfig类,并
设置
了每个实体和一个基本配置。 @Bean("consumerFactoryForFOO"
浏览 16
提问于2020-05-26
得票数 0
1
回答
如何
删除卡夫卡(Spring)中的标题?
、
、
我
使用
以下
KafkaTemplate
来执行此操作:
KafkaTemplate
<String,RequestDto>private ProducerFactory<String<String, RequestDto>
kafkaTemplate
() {
KafkaTemplate
<String, RequestDto> template = new
KafkaTemplate
template.setM
浏览 2
提问于2022-05-30
得票数 1
回答已采纳
2
回答
一
KafkaTemplate
对多KafkaTemplates
、
、
当有几种不同类型的
消息
要发送时,推荐的定义
KafkaTemplate
的方法是什么?只对所有
消息
使用
一个
KafkaTemplate
(带Object),还是为每种类型的
消息
定义每个
KafkaTemplate
?() {}// AddressProducer
浏览 7
提问于2022-11-14
得票数 0
1
回答
Spring Boot:从
KafkaTemplate
获取指标
、
、
我正在
使用
KafkaTemplate
向Kafka写入
消息
。我想从
KafkaTemplate
收集一些指标。我在我的项目中
使用
MicroMeter进行指标收集。
如何
通过MeterRegistry公开
KafkaTemplate
指标?
浏览 14
提问于2020-04-21
得票数 1
回答已采纳
1
回答
带实类通信的嵌入式kafka
、
、
我有
使用
spring-kafka和spring-kafka-test的。我有低于MessageProducer的。@Autowired this.
kafkaTemplate
我尝试过
使用
EmbeddedKafkaRule ,但是我不知道
如何
将它连接到我的应用程序定义的kafka broker,所以当我发送主题
消息
浏览 6
提问于2021-12-05
得票数 0
1
回答
使用
KafkaEmbedded不能保证
消息
顺序吗?
、
、
我
使用
KafkaEmbedded (和
KafkaTemplate
)进行了单元测试,但
消息
顺序是随机的。有没有人知道这是否合乎逻辑,以及这是否可能是担保顺序?<String, byte[]>
kafkaTemplate
= new
KafkaTemplate
<>(new DefaultKafkaProducerFactory<>(producerConfig));
kafkaTemplate
.send(TOPIC, "TEST1&quo
浏览 26
提问于2019-07-04
得票数 0
回答已采纳
1
回答
如何
在spring kafka
消息
中添加自定义
头
值?
、
、
、
我当前
使用
的是spring.kafka.version 1.1.6我发现你可以将kafka元数据
设置
为头部
浏览 12
提问于2018-02-23
得票数 0
4
回答
Spring Kafka中的事务同步
、
我想将kafka事务与存储库事务同步:public void syncTransaction(){
kafkaTemplate
.send我仍然需要
使用
KafkaTemplate
发送我的事件吗?MessageListenerContainer是否禁止向代理发送
消息
?如果我理解正确,
kafkaTemplate
和kafkaTransactionManager必须
使用
相同的producerFact
浏览 4
提问于2017-11-17
得票数 13
回答已采纳
1
回答
刷新一个共享的
KafkaTemplate
<String,Object>与刷新多个特定的KafkaTemplates<String,T>
、
、
、
我在flush中
使用
KafkaTemplate
方法来确保
消息
成功地发送到代理。我有不同的话题和不同的信息类型。服务的示例如下所示。根据
消息
<T>的类型,服务将有几个bean。我计划
使用
那些服务中共享的公共
KafkaTemplate
<String, Object>。 我担心会在不同的服务中刷新相同的共享
KafkaTemplate
<String, Object>。如果我在一个服务bean中调用flush,显然它将触发所有类型的
消息
浏览 5
提问于2022-11-15
得票数 0
1
回答
SpringBoot-Kafka应用程序可以同时扮演消费者和生产者吗
、
在这个应用中,我们
使用
消息
处理它,然后再转发给其他消费者,所以任何人都可以分享一种可能的方法来做到这一点,如果你也能分享一些例子,那就太好了。
浏览 3
提问于2018-02-16
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何设置小程序客服消息通知?
Mastercam如何使用侧铣头
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
access使用MessageBox宏设置支持表达式的提示消息框
QQ如何设置使用代理服务器?
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券