我正在尝试使用ReplyingKafkaTemplate来实现sendAndReceive消息/响应。在执行该服务的服务中,我使用ProducerFactory和ConcurrentKafkaListenerContainerFactory的默认实例来创建ReplyingKafkaTemplate的新实例,如下所示:public class MyService {
private final ReplyingKafkaTemplate<Strin
我使用RequestReplyFuture将响应映射到List,结果如下所示 ? @Service private final ReplyingKafkaTemplatestatic final Logger LOG = LoggerFactory.getLogger(ProductProducer.class);
public ProductProducer(Replying
我想实现Kafka生成器,它发送和接收Java序列化对象。我试过这个:@Configurationprivate String bootstrapAddress;
public ProducerFactory<String, SaleRequestFactory> saleRequestFactoryProducerFactory() {
Map<String, Ob
我正在使用spring-integration来处理从UDP端点到kafka的数据流。我已经在@配置中使用消费者和生产者配置将replyingKafkaTemplate初始化为@Bean。ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
public ReplyingKafkaTemplateProducerFactory<St