Kafka制作人发送无效字符

使用以下代码，我发送Elasticsearch文档以进行索引。 我尝试将基本对象转换为JSON并通过制作人发送。 但是，每条消息（从控制台检查）都附加了像 – t {“productId”：2455这样的乱码字符

public boolean sendMessage() { PageRequest page = new PageRequest(0, 1); Product p = product.findByName("Cream", page).getContent().get(0); String json = ""; ObjectMapper mapper = new ObjectMapper(); try { json = mapper.writeValueAsString(p); } catch (JsonProcessingException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } logger.info("JSON = " + json); boolean status = inputToKafka.send(org.springframework.integration.support.MessageBuilder.withPayload(json).build()); try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } return status; } 

出站配置

任何线索？

使用的插件： Spring Extension Kafka

Answer 1

我今天遇到了这个问题，并通过在生产者配置中设置正确的value-serializer类来解决它，如下所示：

Answer 2

这些可能是您的控制台无法很好地解释的制表符（因为缩进的JSON）。

如果禁用对象映射器生成的输出的缩进，则这些字符可能会消失。

 try { mapper.disable(SerializationFeature.INDENT_OUTPUT); <---- add this line json = mapper.writeValueAsString(p); } catch (JsonProcessingException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } 

Answer 3

卡夫卡不做这样的事情。 调试您发送给Kafka生产者的String消息。 如果您从URL或HTML表单获取此消息，您可能需要先将消息解码，然后再发送给生产者。

例如URLDecoder.decode（消息，“UTF-8”）