Kafka制片人发送无效字符

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

<int-kafka:producer-configuration     broker-list="localhost:9092" topic="headers['kafka_topic']"     key-class-type="java.lang.String" value-class-type="java.lang.String"     key-serializer="kafkaSerializer" value-serializer="kafkaSerializer"/><bean id="kafkaSerializer"  />