我正在尝试设置kafka使用者来处理来自kafka流的数据。我能够设置到流的连接，数据是可见的，但它是特殊字符和ascii的混合体。
我正在使用内置的Kafka控制台，但也尝试了python版本的合流Kafka。唯一需要遵循的参数是使用带有scram-sha-256的sasl\ u明文安全协议。我也愿意使用其他方法来解析输出（如果可能的话，不用java）。
Kafka控制台

bin/kafka-console-consumer.sh --bootstrap-server server:9092 \
--topic TOPIC --from-beginning --consumer.config=consumer.properties

合流KafkaPython

topics = "TOPIC"
conf = {
        "bootstrap.servers": "server:9092",
        "group.id": "group",
        "security.protocol": "SASL_PLAINTEXT",
        "sasl.mechanisms" : "SCRAM-SHA-256",
}
c = Consumer(conf)
c.subscribe([topics])
running = True
while running:
        message = c.poll()
        print(message.value())
c.close()

输出

PLE9K1PKH3S0MAY38ChangeRequest : llZYMEgVmq2CHG:Infra RequestKSUSMAINCHANGEKC-10200-FL01DATA_MISSINGCHGUSD
DATA_MISSINGDATA_MISSINGUSD
CANCEL

▒▒12SLM:Measurement"Schedule(1 = 0)USDUSD▒▒▒
                                                              l▒l▒V?▒▒▒
                                                                       llZYMEgVmq
company_team team_nameTEAM###SGP000000140381PPL000002020234
Latha M▒>▒>▒ChangeRequest
hello:1234543534 cloud abcdef▒▒▒
                                                         ▒Ի▒
                                                            ▒▒▒
                                                               John Smithjs12345SGP000000140381▒NPPL000002020234
▒Ի▒

我最初试图解析标准输出上的数据，但最后的期望是在数据库中获得解析后的数据。如有任何建议，将不胜感激。