有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java apache驼峰流重新排序工作不正常

我阅读了这个(https://camel.apache.org/components/latest/eips/resequence-eip.html#_stream_resequencing)描述,并尝试实现流重新排序。问题在于:

from("kafka:in?brokers=localhost:9092&groupId=test")
                .resequence(header("seqNum"))
                .stream()
                .timeout(10000L)
                .to("kafka:out?brokers=localhost:9092");

我的程序总是等待超时,并且在超时之前不发送消息——即使序列没有任何间隔。例如,我分别发送了4条带有“seqNum”1,3,4,2的消息-它没有间隔,但程序仍在等待超时

我错过什么了吗?也许我得申报一些边界?例如,指定“无间隙”序列的大小? 顺便说一下,设置容量不是一个解决方案


共 (0) 个答案