为 Kafka 消费者实现工厂模式答案

【问题标题】：Implement Factory pattern for Kafka consumer为 Kafka 消费者实现工厂模式
【发布时间】：2021-03-06 16:32:53
【问题描述】：

我想从 Kafka 消费者那里获取响应对象。已满code 如您所见，我将输入转换为工厂对象，而不是使用工厂对象将输入转换为自定义对象。

    ConsumerRecord<String, SaleResponseFactory> consumerRecord = replyFuture.get(10, TimeUnit.SECONDS);
    SaleResponseFactory value = (SaleResponseFactory) consumerRecord.value();
    System.out.println("!!! " + value.getUnique_id());

我不太清楚在这种情况下如何使用工厂模式。一般有更好的解决方案吗？

【问题讨论】：

标签： java apache-kafka

【解决方案1】：

这应该可以使用 Kafka 消费者 API 和适当的反序列化器开箱即用；由于您使用的是泛型ConsumerRecord<String, SaleResponseFactory>

，因此无需强制转换

工厂模式用于构建对象。您在这里所做的只是访问已经反序列化和构建的 Kafka 事件的方法

【讨论】：