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

---

-4熱度

9回答

C＃函數和文本框作爲參數的錯誤

我有一個編寫函數並給它傳遞一個參數的問題。 我的問題是我創建了我的函數mySum。我已經展示了下面的代碼。 注意：我使用了兩個文本框來獲取用戶的值，並且函數應該添加這兩個值並將其顯示在MessageBox中。 void mySum(int a, int b) { int ans; ans = a + b; MessageBox.Show(ans.ToString()

c# parameters 2012-07-16

---

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

---