Spring Cloud Stream Producer在使用Spring Kafka Consumer时添加“垃圾”字符
我们的微服务使用JDK8、Spring Cloud Stream API和Spring Boot 1.5.2版本，用于在Kafka队列上生成消息。对于消费者API，我们使用Spring Kafka 1.1.2.release，特别是@kafkalistener。消息类型为应用程序json
谢谢
共有1个答案
将生产者headermode设置为raw。
请参阅参考文档。
HeaderMode
当设置为raw时，禁用输出上的标头嵌入。仅对本地不支持消息头且需要头嵌入的消息传递中间件有效。在为非Spring云流应用程序生成数据时非常有用。
默认值:embeddedHeaders。
-
我们的微服务使用JDK 8、Spring Cloud Stream API和Spring Boot 1.5.2。用于在Kafka队列上生成消息的释放。对于消费者API，我们使用Spring Kafka 1.1.2。发布，特别是。消息类型是应用程序json 我们注意到，消费者在“contentType”附近的消息中添加了一些垃圾字符，如下所示：JunkCharsInCustomer 在JDK 8中使
-
问题内容： 我有一段代码可以在内存中加载很大的图像。所以打电话似乎是合理的事情 在加载图像之前。据我所知，它毫无问题。 昨天，我决定使用一个名为FindBugs的非常有用的软件来扫描您的代码并报告可能导致错误或通常不建议使用的策略的问题。问题是我提到的这段代码得到了报告。描述是这样的： …强迫垃圾收集；除了基准测试代码外，都非常可疑 并继续阐述： 代码显式调用垃圾回收。除了基准测试中的特定用途外，
-
问题内容： 据我所知，GC仅在JVM需要更多内存时才使用，但我不确定。所以，请有人提出这个问题的答案。 问题答案： 据我了解，Java的垃圾收集算法非常复杂，而且不那么直接。另外，GC可用的算法还不止这些，可以在VM启动时通过传递给JVM的参数进行选择。 这里有一个有关垃圾收集的常见问题解答：http : //www.oracle.com/technetwork/java/faq-140837.h
-
在我的android应用程序中，我正在实现RSA加密解密。 我们有这个适用于ios和android的应用程序。 每当ios用我的公钥加密消息时，都会在base64中发送加密文本，在android端，我会用私钥解密。 问题是，每当我解密数据时，它就会产生被垃圾填充包围的加密消息 如下所示： K������N�t�十、�08���我�二、�z� “test updated pub key”是消息。 我
-
问题内容： Go是一种垃圾回收语言： http://golang.org/doc/go_faq.html#garbage_collection 在这里，它说这是一个标志性的垃圾回收器，但是它没有深入研究细节，并且正在进行替代…但是，自Go发行以来，该段似乎没有太多更新。 它仍然是标记和扫描？是保守还是精确？它是世代相传的吗？ 问题答案： Go 1.4+垃圾收集器的计划： 混合世界/并发收集器 截止
-
问题内容： 我很好奇嵌套函数的node.js模式如何与v8的垃圾收集器一起工作。这是一个简单的例子 如果restofprogram是长时间运行的，那是否不意味着str将永远不会被垃圾回收？我的理解是，使用结点，您最终会获得很多嵌套函数。如果在外部声明了restofprogram，是否会收集垃圾，因此str不能在范围内？这是推荐做法吗？ 编辑 我不想使问题复杂化。那只是粗心，所以我修改了它。 问题答