kafka-join

1熱度

1回答

卡夫卡流API：我加盟empmodel

final KStream<String, EmpModel> empModelStream = getMapOperator(empoutStream); final KStream<String, EmpModel> empModelinput = getMapOperator(inputStream); // empModelinput.print(); // empModelStr

apache-kafka-streams kafka-join 2017-02-27

---

2熱度

1回答

卡夫卡流與JoinWindow工作進行數據回放

我有2個數據流，我希望能夠加入他們1個月的窗口，讓我們說。當我有一個實時數據，一切都是樂趣和超級容易KStream和加入。我做了這樣的事情; KStream<String, GenericRecord> stream1 = builder.stream(Serdes.String(), new CustomizeAvroSerde<>(this.getSchemaRegistryCl

apache-kafka-streams kafka-join 2017-01-23

---