小编HL'*_*REB的帖子

我正在尝试（单元）测试使用Kafka DSL的Spring Cloud Stream Kafka处理器，但收到以下错误“ Connection to node -1 could not be established. Broker may not be available.”。此外，测试不会关闭。我同时尝试了EmbeddedKafka和TestBinder，但是我有相同的行为。我尝试从Spring Cloud Team（有效）给出的响应开始，我将应用程序改编为使用Kafka DSL，并几乎保持了测试类。EmbeddedKafka是否实际上支持Kafka DSL？

我正在使用Elmhurst.RELEASE

@SpringBootApplication
@EnableBinding(MyBinding.class)
public class So43330544Application {

    public static void main(String[] args) {
        SpringApplication.run(So43330544Application.class, args);
    }

    @StreamListener
    @SendTo(MyBinding.OUTPUT)
    public KStream<String,String> process(@Input(MyBinding.INPUT) KStream<String, String> in) {

        return in.peek((k,v) -> System.out.println("Received value " +v ))
                .mapValues(v -> v.toUpperCase());
    }
}

interface MyBinding {

    String INPUT = "input";
    String OUTPUT = "output";

    @Input(INPUT)
    KStream<String, …