apache-kafka

5熱

2答えて

私はKafkaSpoutを使用しています。以下のテストプログラムを見つけてください。私はStorm 0.8.1を使用しています。 MultischemeクラスはStorm 0.8.2にあります。私はそれを使用します。私はちょうどStringScheme（）クラスをインスタンス化することによって以前のバージョンがどのように動作していたのか知りたいですか？以前のバージョンのKafka Spout

21熱

5答えて

Avroバイナリエンコーダを使用してKafkaメッセージをエンコード/デコードする方法は？

私はKafkaから読み書き中のメッセージにAvroを使用しようとしています。誰もAvroバイナリエンコーダを使用してメッセージキューに置かれるデータをエンコード/デコードする例がありますか？私はカフカの部分よりもAvroの部分が必要です。あるいは、私は別の解決策を検討すべきでしょうか？基本的には、私はスペースに関してJSONのより効率的なソリューションを探しています。 AvroはJSONよりコン

6熱

2答えて

Javaコードを使用したストームトポロジの再調整

私はKafkaSpoutを使用している私のStormトポロジーを再調整しようとしています。私のコードは次のとおりです。 TopologyBuilder builder = new TopologyBuilder(); Properties kafkaProps = new Properties(); kafkaProps.put("zk.connect", "localhost

5熱

1答えて

Kafkaのブローカー上のパーティション再バランス0.8

Kafka 0.8に関する比較的稀な文書には、既存のトピック、パーティション、およびブローカー上のレプリカのバランスを取るために期待される動作については言及されていません。具体的には、ブローカーの到着時やブローカー（リーダーまたはそれ以外）のクラッシュ時に予想される動作は何ですか？ありがとうございました。