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

为什么 Kafka 制作人在Spring靴中发布带有双引号的字符串消息

刘浩思
2023-03-14

我正在尝试在Spring启动中将字符串消息发布到Kafka主题中。

我想在Kafka主题中发布没有双引号的消息,如下所示:

IN|TN|2021-03-03 15:22:04.000400|2021-03-03T15:22:09.370002|00000002810000149059|1|8888888888

但它在Kafka主题中发布,带有双引号,如下所示:

"IN|TN|2021-03-03 15:22:04.000400|2021-03-03T15:22:09.370002|00000002810000149059|1|8888888888"

并使用生产者.key序列化器字符串序列化程序生产者.值序列化程序Json序列化程序,并且还尝试了字符串序列化器的值序列化程序,即使问题仍然存在。

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

Message<String> message = MessageBuilder.withPayload(msg).setHeader(KafkaHeaders.TOPIC, this.topicSender)
                .build();

kafkaTemplate.send(message);

任何人都可以在这里帮助我,在Kafka主题中发布没有引号的字符串消息。

共有1个答案

仇阳州
2023-03-14

将生成器值序列化程序配置为StringSerializer

spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
 类似资料:
  • 我无法向Kafka主题发布消息,无法得到Kafka制作人的任何回应,它完全卡住了应用程序 Kafka生产者服务代码 2021-05-30 13:29:13.209[0;39M[32M信息[0;39M[35M2472[0;39M[2M---[0;39M[2M[nio-8084-exec-2][0;39M[36MO.apache.coyote.http11.HTTP11Processor[0;39M[

  • 问题内容: 我有些困惑,为什么我在PHP中看到一些代码,这些代码的字符串用单引号引起来,有时用双引号引起来。 我只是在.NET或C语言中知道,如果用单引号引起来,则意味着它是一个字符,而不是字符串。 问题答案: PHP字符串不仅可以通过 _两种_方式指定,还可以通过 四种 方式指定。 用单引号引起来的字符串几乎可以完全“按原样”显示事物。变量和大多数转义序列将不被解释。唯一的例外是,要显示文字单引

  • 问题内容: 如何在浏览器中显示的JavaScript字符串中包含双引号? 我正在做JavaScript作业,我必须在列表中间加上双引号,如下所示: 问题答案: 使用单引号。 或转义双引号。

  • 问题内容: 我有这个: JSONLint表示这是完全有效的json。但是执行时出现错误。 但是,如果我将代码更改为: (请注意双反斜杠) 它可以工作,但是现在JSONLint表示。 有人可以帮助您了解这种行为吗? 问题答案: 有线格式和您必须在代码中编写的格式之间是有区别的。当您在代码中声明此代码时,您需要在文字中使用双-\,以便字符串获得一个反斜杠(否则,它将\\解释为一个转义序列,仅声明一个“

  • 问题内容: 我正在从数据库中检索数据,其中该字段包含带有HTML数据的字符串。我想替换所有的双引号,使得它可以被用于的 jQuery的 。 使用Java,我正在尝试使用替换引号。 结果字符串未显示所需的更改。O’Reilly的一篇文章规定了使用Apache字符串工具。还有其他办法吗? 是否有正则表达式或我可以使用的东西? 问题答案: 这是如何做 请注意,字符串是不可变的,因此仅仅做是不够的。您必须

  • 我面临一个挑战,要以以下格式匹配输入: 输入由key=value对组成。关键字以斜杠开头。值可以是数字或引号中的字符串。 该值可以选择性地包含转义引号,即引号后面跟着引号(“”)。这种转义引号应该被视为价值的一部分。不需要检查转义引号是否平衡(例如,由另一个转义引号结束)。 正则表达式应该匹配序列中给定的key=value部分,并且对于长输入(例如value是10000个字符)不应该中断。