我正在开发一个使用kafka streams活页夹的春季云kafka应用。org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.registerErrorInfrastructure(AbstractMessageChannelBinder.java:627)
at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.createConsumerEndpoin
我是Apache Kafka技术的新手。我尝试使用python2.7将消息作为JSON对象发送到kafka主题,但是我得到了"AssertionError: Value must be bytes“错误。我可以成功地以字符串形式发送消息,我可以使用kafka-console-consumer.sh查看我的消息。我使用的是apache kafka 2.10-0.8.2.1版本。我在下面给出我的代码。from kafka import KafkaProducer