5熱
5答えて
kafkaをメッセージブローカーとして使用するmqttプロトコルを使用する
7熱
1答えて
17熱
2答えて
カフカの既存のトピックにパーティションを追加することは可能ですか?0.8.2
7熱
2答えて
9熱
2答えて
junitテスト用にMock Kafkaトピックをインスタンス化するにはどうすればよいですか?
8熱
5答えて
kafka consumer 0.9は下位互換性がありますか?
7熱
1答えて
11熱
6答えて
カフカ作成時のエラートピック - 利用可能なブローカーより大きいレプリケーションファクター
7熱
2答えて
PySparkでオフセット付きのInputDStreamを作成するにはどうすればいいですか?(KafkaUtils.createDirectStreamを使用して)
80熱
3答えて