confluent-platform - 合流云| Java Avro 序列化 |垃圾字符的值(value)

Question

我正在尝试使用 Java 中的基本 Avro 发布器，该发布器在示例中可用
https://github.com/confluentinc/examples/blob/5.5.1-post/clients/avro/src/main/java/io/confluent/examples/clients/basicavro/ProducerExample.java
我成功地在我的本地机器 (macOS) 和 GCP 中可用的机器(自我管理的融合二进制文件)中在自我管理的融合云中发布

同样试了一下融合云
我有一个融合的云访问，我正在尝试使用相同的示例，但它显示了垃圾字符的值(value)。

在融合云中执行的步骤

通过名称事务手动创建主题

配置文件是用以下条目创建的

通过传递绝对文件路径配置来运行 java 应用程序。

我能够看到模式也设置在融合云中。

你们中的任何人都可以在这里帮助我，因为缺少什么。

Answer 1

您的数据是正确的； Confluent Cloud 消息查看器当前(2020 年 9 月)不支持呈现 Avro 消息。
您可以使用消费者(例如 kafkacat)来验证您的数据是否正确:

docker run --rm edenhill/kafkacat:1.6.0 \
         -X security.protocol=SASL_SSL -X sasl.mechanisms=PLAIN \
         -X ssl.ca.location=./etc/ssl/cert.pem -X api.version.request=true \
         -b ${CCLOUD_BROKER_HOST} \
         -X sasl.username="${CCLOUD_API_KEY}" \
         -X sasl.password="${CCLOUD_API_SECRET}" \
         -t your_topic \
         -C -o beginning \
         -f 'Topic %t[%p], offset: %o, Headers: %h, key: %k, payload: %S bytes: %s\n ' \
         -s avro -r https://"${CCLOUD_SCHEMA_REGISTRY_API_KEY}":"${CCLOUD_SCHEMA_REGISTRY_API_SECRET}"@${CCLOUD_SCHEMA_REGISTRY_URL}