可以在没有代理的情况下创建 KafkaReceiver 吗？

问题描述

我正在使用 reactor-kafka 为 Kafka 消息创建反应式使用者，并且我正在寻找一种创建单元测试的方法。

例如，在以下消费者中，我想验证对 commit 的调用是否已执行。

import reactor.kafka.receiver.KafkaReceiver;

class ReactiveEventConsumer {
    public ReactiveEventConsumer(KafkaReceiver<Integer,Object> kafkaReceiver) {
        kafkaReceiver
                .receive()
                .doOnNext(record -> System.out.println("Kafka message received " + record))
                .doOnNext(record -> record.receiverOffset().commit())
                .subscribe();
    }
}

我知道我可以设置一个 EmbeddedKafka 并根据代理属性创建 KafkaReceiver。这有点开销，因为我希望我的测试专注于反应性部分而不是 kafka 部分。

我可以在没有代理的情况下创建 KafkaReceiver 吗？

或者有其他方法可以测试这种设置吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）