Avro 模式对象通用 kafkaTemplate 类型 - 生成消息答案

【问题标题】：Avro schema object generic kafkaTemplate type - produce messageAvro 模式对象通用 kafkaTemplate 类型 - 生成消息
【发布时间】：2021-10-04 03:37:23
【问题描述】：

我的 kafka 模板如下所示：

KafkaTemplate<String, InternalSelfServiceData> kafkaTemplate;

位置： InternalSelfServiceData -> Avro 模式对象

当我调用kafkaTemplate.send() 时，我的返回类型是ListenableFuture<SendResult<String, InternalSelfServiceData>>。接下来我将此数据作为参数传递给下一个方法，但我希望这个方法是通用的，所以我希望他们接受像这样的参数ListenableFuture<SendResult<String, ? extends SpecificRecordBase>>。

IntelliJ出现的错误是：

必填类型：可听的未来 >

提供：ListenableFuture

有什么我想念的建议吗？

【问题讨论】：

标签： java apache-kafka avro kafka-producer-api

【解决方案1】：

尝试将您的数据编码为 bytearray (org.apache.avro.specific.SpecificDatumWriter)

【讨论】：

你能告诉我与我问的问题相关的例子吗？我的意思是使用 SpecificDatumWriter 来维护 kafkaTemplate 和 ListenableFuture？
在将数据发送到队列时遇到了提供和所需类型不匹配的问题，因此使用 Writer 类进行编码并作为字节数组发送