confluent-platform - 汇合云 | Java Avro 序列化 | 值中的垃圾字符

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 中可用的机器中发布了自我管理的融合云（自我管理的融合二进制文件）

同样尝试了融合云

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

在融合云中执行的步骤

1. 按名称事务手动创建主题
2. 使用以下条目创建了配置文件
3. 通过传递绝对文件路径配置来运行 java 应用程序。
4. 我能够看到架构也设置在融合云中。

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

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}