2回答
Service3，消息生产者，通过绑定器-卡夫卡向消费者Service4发送消息。
我用春云雪橇来追踪它们之间的跨度。但是在zipkin服务器中，只有Service3中的spans可用。:spring-boot-starter-thymeleaf') compile('org.springframework.cloud:spring-cloud-starter-sleuth') //:spring-cloud-strea
浏览 9提问于2017-02-22得票数 0
3回答
我正在尝试使用Spring Cloud Stream来集成Kafka。正在编写的消息是Java POJO，虽然它的工作方式与预期一样(消息正在写入主题，我可以使用消费者应用程序读取)，但消息的开头添加了一些未知字符，这在尝试集成Kafka Connect以接收主题中的消息时会造成麻烦在默认设置下，这是推送到Kafka的消息：
contentType "text/plain"
浏览 1提问于2017-11-21得票数 3
回答已采纳
2回答
我必须在kafka消息中设置一个自定义标题，我的kafka集群本机支持报头(1.x.x)。我目前正在使用springCloudVersion=Finchley.RELEASE。当我设置属性时 producer:输出中没有任何一个标头。另一方面，如果我正在设置 producer:包括contentType和spr
浏览 3提问于2019-10-29得票数 0
回答已采纳
1回答
我使用Kafka实现微服务之间的Asyng调用，使用Spring进行日志记录。日志记录是正常的，但是当有消息从Microservice1到Microservice2时，日志记录的消息具有不同的跟踪ID。难道他们不需要有相同的追踪Id但有不同的SpanId吗？有没有特殊的配置？
浏览 2提问于2016-12-02得票数 4
回答已采纳
我使用redis作为spring分布式env的消息存储库。我将消息头设置如下，在检查在处理器中接收到的消息时，它只显示id和时间戳。发送时的标头
[Headers={columnNames=abc,def, id=74acf995-ec39-0e
浏览 2提问于2014-08-01得票数 2
回答已采纳
我试着用Spring实现一个非阻塞的重试。根据文档，我们可以设置一个处理程序方法来处理来自DLT主题的消息，在@KafkaListnener中完成了穷尽的尝试之后。我为这些头尝试了一些值，如KafkaHeaders.DLT_ORIGINAL_OFFSET、KafkaHeaders.OFFSET等。在Spring代码中，我看到一些标头以字符串"kafka_“作为前缀，并且在消息上看到了这些<
浏览 7提问于2021-09-17得票数 0
我有一个简单的项目，它使用流和Kafka绑定器。一切都很好，但是来自卡夫卡的消息头值作为byte[]到达。我已经将Kafka客户端配置为使用StringSerializer/StringDeserializer。我想，我还需要以某种方式告诉Spring，哪些头要映射为Sp
浏览 3提问于2019-10-26得票数 7
回答已采纳
我对springboot kafka是个新手，我在这篇文章之后创建了一个例子。我当前使用的是spring.kafka.version 1.1.6我发现你可以将kafka元数据设置为头部
浏览 12提问于2018-02-23得票数 0
2回答
我计划使用Spring Kafka客户端在Spring Boot应用程序中使用kafka设置并生成消息。我在Kafka 0.11中看到了对自定义头部的支持，作为详细的。虽然它对原生Kafka生产者和消费者是可用的，但我不认为Spring Kafka支持添加/读取自定义头部。我正在尝试基于重试计数为消息实现DLQ，我希望将重试计数存储在<
浏览 1提问于2018-02-15得票数 5
回答已采纳
1回答
我使用来自Edgware发行版的Spring 绑定器发送卡夫卡消息。我还使用了Spring 和Zipkin。我的问题是:是否有一种为消息头(例如普通JSON)配置自定义编码器&#x
浏览 3提问于2018-01-09得票数 1
回答已采纳
2回答
我需要向集群中运行的Flink作业添加track和span，请求流如下所示我使用Spring引导来创建rest API，并使用spring Sleuth向生成的日志添加跟踪和span id，在调用rest和将消息放到Kakfa-Top-1上时添加跟踪和spani
浏览 3提问于2019-11-22得票数 0
对于在Kafka绑定器中生成/使用的消息头的管理，有一个KafkaHeaderMapper接口，它作为bean的实现可以配置以下属性：spring.cloud.stream.kafka.binder.headerMapperBeanNameStream中的KafkaStreams绑定器有类似的地方吗？我的意图是能够控制如何在流输入和输出中反序列化/序列化或包括/排除消息头。有人知道如何意
浏览 17提问于2022-01-18得票数 0
我必须路由来自两个不同的kafka主题的事件，我不知道如何将功能路由器0绑定到两个不同的目的地。路由将通过向生产者端的每个消息添加一个spring.cloud.function.definition头来完成。假设我有
具有具有值topic1或consumerB值的spring.cloud.functio
浏览 1提问于2021-03-30得票数 0
回答已采纳
我使用Spring数据流来设置读取CSV文件的流，使用自定义处理器对其进行转换并对其进行日志记录：也会为file_relativePath头引发此异常。我不明白为什么spring会把它们解读为JSON。k
浏览 8提问于2019-12-03得票数 1
回答已采纳
我使用和功能接口来处理我的kafka处理。application.yml (相关部分) cloud: kafka: brokersminPartitionCount: 2 receive
浏览 1提问于2020-04-22得票数 0
回答已采纳
我有一个使用Spring-Kafka的Spring Boot应用程序，我使用docker中的landoop's fast-data-dev作为我的kafka集群。但是，当我进入快速数据开发ui时，我可以看到我的模式已注册，我的消息仍然显示为Data type: binary，而不是'avro‘，因此它们的值在ui中不可读。我尝试使用kafka- avro -console-producer发送一些消息</e
浏览 33提问于2019-05-06得票数 0
我使用的是Spring cloud stream绑定器kafka，Edgware.SR4版本。制片人：spring:
浏览 130提问于2019-05-24得票数 0
1回答
我有两个用Java编写的微服务，使用Spring。，通过，在它们之间发送消息。我需要发送一个自定义头，但到目前为止没有成功。我在互联网和Spring 上已经阅读和尝试了大多数东西。任何帮助都将是wellcome
提前谢谢。MessageBuilder.createMessage(payl
浏览 5提问于2020-10-29得票数 0
我的想法是使用主题本身对失败的消息进行重新排队。但是具有两个附加的报头值kafka_try-counter和kafka_try-timestamp。报头并生成同一主题中的消息。RePublishingErrorHandler检查标头值，如果kafka_try-counter退出最大尝试次数，则调用另一个ConsumerRecordRecoverer，如DLT或日志记录。使用的kafka_try-timestamp决定
浏览 1提问于2020-03-11得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
