apache-kafka-streams

2熱

1答えて

StreamsException：抽出されたタイムスタンプ値が負であり、許可されていません

これはError in Kafka Streams using kafka-node - negative timestampの複製である可能性がありますが、確かにそうではありません。私のKafka Streamsアプリケーションは、各メッセージに対していくつかの変換ロジックを行い、それを新しいトピックに転送します。時間ベースの集計/処理はアプリにはないので、カスタムのタイムスタンプ抽出機能を使用

apache-kafka apache-kafka-streams 2016-12-27

---

2熱

1答えて

Kafka Streams 0.10.1 "状態ストアをフラッシュできませんでした"

Kafka Streams 0.10.1を使用してScalaで単純な集計の例を作成しようとしていますが、単純な「集計」集計で失敗するようですプロデューサー）。このようなコードで： val inputStream: KStream[String, String] = builder.stream("inputTopic") inputStream .map(new KeyValueMa

scala apache-kafka-streams 2016-12-30

---

0熱

1答えて

Kafka-Streamを使ってKafka-Streamを使ってレコードを読み取る方法

私はKafka-StreamコンシューマでKafkaのレコードを読みたいと思っています。例えば1分ごとに？

kafka-consumer-api apache-kafka-streams 2017-01-02

---

1熱

1答えて

カフカストリーム - 2つのktablesを結合すると2回結合関数が呼び出されます

2つのKTablesに結合しようとしています。 KTable<String, RecordBean> recordsTable = builder.table(Serdes.String(), new JsonPOJOSerde<>(RecordBean.class), bidTopic, RECORDS_STORE); KTable<String, ImpressionB

apache-kafka apache-kafka-streams 2017-01-02

---

2熱

1答えて

Apache Kafkaでの状態の構築とクエリ：Kafka Stream？

私のニーズに合ったApacheクラスタを構築しており、そのほとんどはステートレスです。しかし、私には本当に状態が必要な状況が1つあります。 説明するには、開店するすべての薬局店舗とその店舗で発生する取引をすべて保存しているとします。店は薬の数の初期状態で開きます。医薬品が販売され、より多くの医薬品が貯蔵されるにつれて、状態は絶えず変化し続ける。 リアルタイムでライブ取引に対応する必要がある一方で、

apache-kafka apache-kafka-streams stateful 2017-01-08

---

3熱

1答えて

カフカストリームの集計には発注保証がありますか？

私のカフカトピックには、deviceIdによってキーされたステータスが含まれています。 KStreamBuilder.stream().groupByKey().aggregate(...)を使用して、ステータスの最新値をTimeWindowに保存するだけです。私は、トピックがキーで仕切られている限り、集約関数は常にこの方法で最新の値を返すことができる、ということを推測： (key, value,

apache-kafka-streams 2017-01-09

---

2熱

1答えて

KafkaStreams - InconsistentGroupProtocolException

私はそうのように、カフカストリームDSLを使用して、当社のカフカクラスタに接続カフカストリームアプリを持っている： KStreamBuilder builder = new KStreamBuilder(); KStream<String, byte[]> stream = builder.stream(myTopic); // do work kStreams = new KafkaS

apache-kafka apache-kafka-streams 2017-01-11

---

0熱

1答えて

Apache Kafka Streamsビルドと開始jar

Apache Kafka Streamsのための小さなテストプログラムをプログラムしたいと思います。私がこれまで行ってきたのは、 Intellijをインストールします。 gitのソースコードをコピーします。 unzipedフォルダにgradle wrapperとgradle ideaを実行してください。 Intellijでフォルダをインポートします。 streams/examples/src/ma

java intellij-idea jar apache-kafka apache-kafka-streams 2017-01-13

---

8熱

1答えて

カフカ入力ストリームを複数の出力ストリームに動的に接続する

カフカストリームには、単一の入力ストリームを複数の出力ストリームに動的に接続できる機能が組み込まれていますか？ KStream.branchは真/偽の述語に基づいて分岐を許可しますが、これは私が欲しいものではありません。実行時にストリーミングされるトピックを決定するために、着信する各ログを希望します。たとえば、{"date": "2017-01-01"}というログはトピックtopic-2017-0

java apache-kafka apache-kafka-streams 2017-01-22

---

5熱

3答えて

カフカストリーミング+スパークストリーミング+マシンラーニング

私は、データストリーム上でマシンラーニングアルゴリズムを実行するためのPOCをやっています。 Spark Streaming - >複数のテーブルのデータを集計 - > Stream of Data上でMLLibを実行する - >出力を生成するというデータを取得するのが最初のアイデアでした。 しかし、私はコンフルエントのカフカストリーミングを見ています。今私は混乱している！ 質問： 1. Spar

apache-spark machine-learning apache-kafka spark-streaming apache-kafka-streams 2016-12-13

---