我希望看到在Kafka中为我的流/表运行的查询。Create stream foo as select * from bar where distuinguisher='xxx';
-------------------------------------------------------- 一旦有人创建了流/表,我只能查询流/有没有什
当使用Kafka流DSL时,是否有一种方法可以使用相同的主题作为两个不同处理例程的源?StreamsBuilder streamsBuilder = new StreamsBuilder();
streamsBuilder.stream("topic")...
// use the same topic as a
我试图使用Spring编写一个Kafka流处理器,但是在主题中生成消息时不会调用它。这些都是主题。: stream-client [LocationService-9611eedf-df9b-4fe5-9a7d-058027cee22a] Topology with no input topics: Could not