根据本主题:
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;
}
是的,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/*”,但它也不起作用。 这里有人能帮助我吗,如果它可能或不可能,或者我在这里做错了什么