apache-kafka-streams

2熱度

1回答

Kafka Stream：KTable vs GlobalKTable and KStream - leftJoin（）vs outerJoin（）

在Kafka Stream庫中，我想知道KTable和GlobalKTable之間的區別。 另外在KStream類中，有兩個方法leftJoin（）和outerJoin（）。這兩種方法還有什麼區別。 我讀http://docs.confluent.io/current/streams/javadocs/org/apache/kafka/streams/kstream/KStream.html#le

apache-kafka apache-kafka-streams 2017-08-31

---

1熱度

1回答

使用kafka流創建包含多個聚合的新KStream

我正在發送包含有關Web服務請求和對Kafka主題的響應的詳細信息的JSON消息。我想在使用Kafka流到達Kafka時處理每條消息，並將結果作爲不斷更新的摘要（JSON消息）發送到客戶端連接的WebSocket。 然後客戶端將解析JSON並在網頁上顯示各種計數/摘要。 樣品輸入消息如下 { "reqrespid":"048df165-71c2-429c-9466-365ad057eac

apache-kafka-streams 2017-09-01

---

1熱度

1回答

在Kafka中查詢全局狀態存儲Streams會拋出Null異常

使用Processor API和addGlobalStore函數創建全局KTable時，生成的存儲會填充OK。但隨後嘗試遍歷商店的內容導致以下異常： Exception in thread "main" java.lang.NullPointerException at org.apache.kafka.streams.state.intern

apache-kafka apache-kafka-streams 2017-09-01

---

1熱度

1回答

我應該使用什麼：卡夫卡流或卡夫卡消費者API或卡夫卡連接

我想知道什麼對我最好：卡夫卡流或卡夫卡消費者API或卡夫卡連接？ 我想從主題讀取數據，然後做一些處理並寫入數據庫。所以我寫了消費者，但我覺得我可以編寫Kafka流應用程序，並使用它的有狀態處理器執行任何更改並將其寫入數據庫，這可以消除我的使用者代碼，並且只需編寫db代碼。 數據庫我想插入我的記錄是： HDFS - （插入生JSON） MSSQL - （處理JSON） 另一種選擇是卡夫卡連接，但我發

apache-kafka kafka-consumer-api apache-kafka-streams apache-kafka-connect confluent-kafka 2017-09-04

---

1熱度

2回答

卡夫卡與斯卡拉

我試圖用卡夫卡與斯卡拉 下面是我在Java代碼中，其工作完全正常流流scala代碼會引發編譯錯誤。類型不匹配預期：ForEachAction [>字符串，>字符串]，實際（（任意，任意），單位） 未發現：價值關鍵 未發現：值值 有誰知道如何使用流API中scala

scala apache-kafka kafka-consumer-api apache-kafka-streams 2017-09-04

---

1熱度

1回答

阿帕奇卡夫卡：處理器生成每個輸入

多輸出我有一個具有把一個項目作爲輸入卡夫卡流處理器，和產生多個項作爲輸出。 什麼是正確的編碼方式？多次撥打電話this.context().forward(key, item)是正確的做法，還是有另一個作弊？ 謝謝。

java apache-kafka kafka-consumer-api apache-kafka-streams 2017-09-05

---

5熱度

1回答

Kafka streams.allMetadata（）方法返回空列表

所以我試圖獲得使用Kafka流的交互式查詢。我有Zookeeper和Kafka在本地運行（在Windows上）。我在哪裏使用C：\ temp作爲存儲文件夾，適用於Zookeeper和Kafka。 我已經安裝這樣 kafka-topics.bat --zookeeper localhost:2181 --create --replication-factor 1 --partitions 1 --t

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-09-05

---

0熱度

1回答

使用我自己的Cassandra驅動程序編寫聚合結果

我正試圖創建一個簡單的應用程序，它向我的網站上的每個網頁的頁面視圖寫入Cassandra。我想從邏輯小時開始每5分鐘寫一次累積頁面瀏覽量。 我給這家代碼看起來是這樣的： KTable<Windowed<String>, Long> hourlyPageViewsCounts = keyedPageViews .groupByKey() .count(TimeWindow

apache-kafka-streams 2017-09-07

---

0熱度

2回答

我可以在Kafka Broker的同一臺機器上運行Kafka Streams應用程序嗎？

我有一個卡夫卡流應用程序，它從幾個主題中獲取數據，並加入了數據，並把它放在另一個話題。 卡夫卡配置： 5 kafka brokers Kafka Topics - 15 partitions and 3 replication factor. 注：我在哪裏我的卡夫卡經紀人運行相同的機器上運行卡夫卡流應用。 的幾百萬美元的記錄被消費/製造每隔一小時。每當我拿下任何一家卡夫卡經紀商時，它都會進入

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-09-12

---

1熱度

1回答

Kafka Stream重新平衡舊消息

我有一個Kafka Streams應用程序，它從少量主題獲取數據並加入數據並將其放入另一個主題中。 卡夫卡配置： 5 kafka brokers Kafka Topics - 15 partitions and 3 replication factor. 我運行在哪裏我的卡夫卡經紀人正在運行同樣的機器卡夫卡流應用。 每小時消耗/產生幾百萬條記錄。每當我把任何一個卡夫卡經紀人放下時，它會在重新

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-09-13

---