kafka-producer-api

1熱

1答えて

Apache Kafka：KafkaProducerActorが例外ASkタイムアウトをスローします。

ケーキ溶液Akka client for scala and Kafkaを使用しています。 KafkaProducerActor俳優を作成していて、askパターンを使用してメッセージを送信しようとしていますが、将来、いくつかの操作を実行しますが、毎回askタイムアウト例外に直面しています。以下は私のコードです：後 class SimpleAkkaProducer (config: Config,

0熱

1答えて

ドッカーのコンテナにローカルカフカを接続するにはどうすればいいですか？

私はローカルホストにkafkaサーバを持っています。私はそれを私のドッカーコンテナに接続したいと思っています。私は、ドッキングウィンドウコンテナにローカルサービスを接続する方法を探索していたし、私はこれが見つかりました：how-to-connect-to-local-mysql-server-through-docker をしかし、それは動作しませんでした。どうか私の助けてくれてありがとう〜

0熱

2答えて

rsyslogのomkafkaモジュールで許可が拒否されました

omkafkaモジュールを使用して、リモートマシンのrsyslogからkafkaへのメッセージを公開しようとしています。 My omkafka action is configured as: if $HOSTNAME == 'localhost' then { action(type="omkafka" name="log_kafka" broker="192.1

0熱

1答えて

Kafka Python Client - 可能な接続/タイムアウトエラーを処理する方法は？

私はKafkaのキューに接続し、キューにメッセージを送信するPythonアプリケーションを書いています。私は私が直面するかもしれない例外のいずれかの種類をキャッチできるように、このコードでは、標準のtry-catch式を追加したい def send_msg(self, topic, msg): self.producer = KafkaProducer(bootstrap_servers

0熱

1答えて

kafka最大スループット（MB /秒）

kafkaの最大スループットはMB /秒で表されます。サイズが2MBのメッセージを送信しようとしていて、毎秒約30レコード（つまり60MB /秒）のスループットを得ようとしています。理論上の最大スループットに達したかどうか確認したいと考えました。

0熱

1答えて

カフカオペレーションの遅延

テスト中にトピックを削除するような操作をします。 immeidatelyそれをを削除した後に使用しかし、私はトピックを参照してくださいすることができます。bin/kafka-topics.sh --list --zookeeperはlocalhost：2181 をそれが実際に発生して削除するためのいくつかの時間がかかります。これは私を混乱させます。私がデータを生成するとき、私はすぐに消費する

1熱

1答えて

複数のコンシューマーで同じカフカメッセージを読む方法

私はKakfa Springの統合には非常に新しいです。私はKafkaのメッセージ送信とOne Listenerを実装しました。それは私のためにうまくいきます。しかし、私はListenerと同じメッセージを2つの場所に送りたい。誰でも私を助けることができます。以下は私のコードです。 spring.kafka.bootstrap-servers=localhost:9092 spring.kafk

0熱

1答えて

Kafkaのパーティション数を増やすと、メッセージがRoundRobin順に配信されない

こんにちは私はkafkaに新しいです。私はkafkaバージョン0.10.2とzookeeperバージョン3.4.9を使用しています。私は2つのパーティションと2つの消費者が走っているトピックを持っています。そこで、処理スピードを上げるために、私は消費者の数を増やすことができるように、パーティションの数を10に増やすことに決めました。だから私は、コマンドを実行した ./kafka-topics.sh

0熱

2答えて

kafka customet partioner error

私はカスタムプロジェクトを作成しましたが、どちらも同じプロジェクトで作成されていますが、なぜ私はエラーが発生しているのでしょうか。私はthis.Bowowプログラムでカフェカプロデューサプログラムです。 SensorPartitionerクラスが見つからないため、エラーが発生しました。エラー：SensorPartitionerクラスに Exception in thread "main" org