如何查找DLQ主题的记录值格式。我可以看到很少的dlq使用json，也很少有其他dlq主题使用byte。在主题配置中也无法识别此问题。任何人都可以请提供参考文件也如果你有。
xqkwcwgp1#
从主题名称/config本身看不出这一点;你需要跟踪设置序列化器的源代码。如果您使用Confluent Schema Registry /ConnectConverters，那么您就有更大的可能性可以知道，但是查询它的API，但这并不能保证，除非您还在代理上为这些主题强制执行服务器端模式验证但是，所有Kafka数据都可以作为字节数组使用，所以你可以添加一个try-catch来测试String/JSON和其他格式。
1条答案
按热度按时间xqkwcwgp1#
从主题名称/config本身看不出这一点;你需要跟踪设置序列化器的源代码。如果您使用Confluent Schema Registry /ConnectConverters，那么您就有更大的可能性可以知道，但是查询它的API，但这并不能保证，除非您还在代理上为这些主题强制执行服务器端模式验证
但是，所有Kafka数据都可以作为字节数组使用，所以你可以添加一个try-catch来测试String/JSON和其他格式。