Spring的云流：Kafka接收器收到另一条消息

Question

我正在尝试用kafka绑定构建一个简单的云流应用程序。让我描述一下设置。1、我有一位制作人正在制作主题1
2。有一个流活页夹，经过一些处理后将主题1绑定到主题2。

@StreamListener(MyBinder.INPUT)
    @SendTo(MyBinder.OUTPUT_2)
    public String handleIncomingMsgs(String s) {
        logger.info(s);  // prints all the messages
        return s;
    }

java prettyprint-override">@Service
@EnableBinding(MyBinder.class)
public class LogMsg {

    @StreamListener(MyBinder.OUTPUT_2)
    public void handle(String board) {
        logger.info("Received payload: " + board); //prints every alternate messages
    }

public interface ViewsStreams {

    String INPUT = "input";
    String OUTPUT_1 = "output_1";
    String OP_USERS = "output_2";

    @Autowired
    @Input(INPUT)
    SubscribableChannel job_board_views();

    @Autowired
    @Output(OUTPUT_1)
    MessageChannel outboundJobBoards();

    @Autowired
    @Output(OUTPUT_2)
    MessageChannel outboundUsers();
}

我是这些技术的新手。无法弄清楚这里出了什么问题。有人能帮忙吗？

Answer 1

你的猜测是正确的；OUTPUT\u 2通道上有两个使用者—侦听器和发送消息的绑定。

他们每个人都会收到备用消息。