apache-kafka-streams

1熱

1答えて

以下のコードでは、stream1とstream2の両方が個別にうまく動作し、出力が見えますが、結合ストリームは全く何も記録しません。私はそれがジョインウィンドウと何か関係があると感じていますが、両方のストリームからのデータはほとんど同じ時刻に入ります。 val stream = builder.stream(stringSerde, byteArraySerde, "topic") val s

0熱

1答えて

は、私はHDP 2.4プラットフォーム上でコンフルエントをインストールすることができます私は可能ではないかもしれないと思うカフカのストリームのHDP上でコンフルエントをインストールしようとしている

は、あなたの人々は何をすべきかを私に提案することができあなたがコンフルエントをインストールしようとしているように思え

2熱

2答えて

kafka ktable - java経由でのアクセス

今朝、ローリングウィンドウのKey-Valueストアを実装するため、ktablesについて読んでいます。私はカフカの最新リリースがこれが可能であることを示唆しているように見えますが、私は「外部」アプリケーションからキーバリューデータにアクセスすることについてもっと疑問に思っています。私はkstreamsアプリケーションを実装しているとし、トピックからログデータ（またはそれはilk）を消費し、気晴

3熱

1答えて

Kafkaストリームを使用したワーク配布

私はカフカストリームを使用して、カフカのトピックで並行作業を行っています。ストリームは、以下のフォーム stream(topic) .map(somefunction) .through(secondtopic) である私は、15個のワーカースレッドを持つようにKStreamsを設定しましたが、作業が正しく（あるいは全くない）スレッド間でバランスされていないように思えます。セットアップに

0熱

1答えて

未使用のkafkaコンシューマグループを削除

私はConfluent/Apache Kafka 0.10を、分散キャッシュ同期メカニズムとして圧縮されたトピックで使用しています。アプリケーションが起動すると、インスタンス固有のコンシューマ・グループIDが生成されます。インスタンスが追加され、水平スケーラビリティのために削除されると、明らかに、再び使用されるべきではない多数のグループIDが得られます。私はこれがKStreamsとKTables