当前位置: 首页 > 知识库问答 >
问题:

SpringCould SteamKafka支持嵌入式头吗?

顾永福
2023-03-14

根据本主题:
Kafka Spring Integration:Headers not for Kafka consumer-这不是对Kafka的Headers支持

但文件上说:

我无法使用Spring-Cloud-Stream-Binder-Kafka:1.2.0版本

正在发送日志:

MESSAGE (e23885fd-ffd9-42dc-ebe3-5a78467fee1f) SENT : 
GenericMessage [payload=..., 
headers={
   content-type=application/json, 
   correlationId=51dd90b1-76e6-4b8d-b667-da25f214f383, 
   id=e23885fd-ffd9-42dc-ebe3-5a78467fee1f, 
   contentType=application/json, 
   timestamp=1497535771673
}]

接收日志:

MESSAGE (448175f5-2b21-9a44-26b9-85f093b33f6b) RECEIVED BY HANDLER 1: 
GenericMessage [payload=..., 
headers={
    kafka_offset=36, 
    id=448175f5-2b21-9a44-26b9-85f093b33f6b, 
    kafka_receivedPartitionId=0, 
    contentType=application/json;charset=UTF-8, 
    kafka_receivedTopic=new_patient, timestamp=1497535771715
}]

MESSAGE (448175f5-2b21-9a44-26b9-85f093b33f6b) RECEIVED BY HANDLER 2 :
GenericMessage [payload=..., 
headers={
    kafka_offset=36, 
    id=448175f5-2b21-9a44-26b9-85f093b33f6b, 
    kafka_receivedPartitionId=0, 
    contentType=application/json;charset=UTF-8, 
    kafka_receivedTopic=new_patient, timestamp=1497535771715
}]
spring.cloud.stream.kafka.binder.headers=correlationId
spring.cloud.stream.bindings.newTest.destination=new_test
spring.cloud.stream.bindings.newTestCreated.destination=new_test
spring.cloud.stream.default.consumer.headerMode=embeddedHeaders
spring.cloud.stream.default.producer.headerMode=embeddedHeaders

正在发送消息:

@Publisher(channel = "testChannel")
public Object newTest(Object param) {
    ...
    return myObject;
}

共有1个答案

姜卜霸
2023-03-14

是的,http://docs.spring.io/spring-cloud-stream/docs/chelsea.sr2/reference/htmlsingle/index.html#_consumer_properties

头模式

设置为raw时,禁用输入的头解析。仅对本机不支持消息头且需要嵌入头的消息传递中间件有效。当入站数据来自Spring Cloud Stream应用程序外部时非常有用。

但那已经是春天的云流故事,而不是春天的卡夫卡本身。

 类似资料:
  • 案例 Basic css 我们绑定 styled-jsx 来生成独立作用域的 CSS. 目标是支持 "shadow CSS",但是 不支持独立模块作用域的 JS. export default () => <div> Hello world <p>scoped!</p> <style jsx>{` p { color: blue;

  • 我想使用REST API的HAL格式来包含嵌入式资源。我在API中使用Spring HATEOAS,Spring HATEOAS似乎支持嵌入式资源;但是,没有关于如何使用此功能的文档或示例。 有人能提供一个如何使用Spring HATEOAS包含嵌入式资源的例子吗?

  • 问题内容: 我可以在文件中保留这样的嵌入式注释吗? 我不希望在CSS输出中使用此注释。 问题答案: 在SASS中要考虑两种不同类型的注释。 单行注释将由.scss预处理器删除,并且不会出现在.css文件中。 多行注释是有效的CSS,在从.scss到您的.css文件的转换之间将保留*。 听起来内联注释是您想要的。

  • 本文向大家介绍Spring Boot支持哪些嵌入式容器?相关面试题,主要包含被问及Spring Boot支持哪些嵌入式容器?时的应答技巧和注意事项,需要的朋友参考一下 无论何时创建Java应用程序,都可以通过两种方法进行部署: 使用外部的应用程序容器。 将容器嵌入jar文件中。 Spring Boot包含Jetty,Tomcat和Undertow服务器,所有服务器都是嵌入式的。 Jetty - 用

  • 本文向大家介绍Spring Boot如何支持嵌入式Servlet容器,包括了Spring Boot如何支持嵌入式Servlet容器的使用技巧和注意事项,需要的朋友参考一下 Spring Boot支持Tomcat、Jetty和Undertow三种Servlet容器嵌入到Web应用程序中,开发者使用starter即可方便嵌入,默认情况下,嵌入服务器的访问端口为8080。 Servlets、Filter

  • 我正在寻找在嵌入式Jetty WebAppContext contextPath中的通配符支持,但无法找到任何。我有以下代码为我的购物WebApp: 我希望,如果访问http://ip:port/shopping/任何东西,它应该加载我上面的WebApp。但事实并非如此。我也尝试了path=“/shopping/*”,但它也不起作用。 这里有人能帮助我吗,如果它可能或不可能,或者我在这里做错了什么