reactive-kafka

0熱

1答えて

Akka-Streamを使用してReactive Kafkaの大きなメッセージをチャンクして再作成する方法

Kafkaを使用して大きなファイルを送信する場合、パーティションに分散してからAkka-Streamを使用して再アセンブリすることは可能ですか？このプレゼンテーションで説明したように： http://www.slideshare.net/JiangjieQin/handle-large-messages-in-apache-kafka-58692297

scala apache-kafka akka-stream reactive-kafka 2016-09-30

---

0熱

2答えて

見つかりjava.util.concurrent.Future必要scala.concurrent.Future

関連：私はアッカHTTPアプリケーションを持っている、と私は」 How to integrate akka streams kafka (reactive-kafka) into akka http application? ：scala.concurrent.Future wrapper for java.util.concurrent.Future これは私の他の質問から来ました以下のように、

scala apache-kafka akka akka-http reactive-kafka 2017-09-18

---

0熱

1答えて

Akka Streams KafkaでProducerMessageを構築する際にオフセットパラメータを設定する方法は？

私はScala 2.11とAkka Streams Kafka 0.17を使用しています。 私はストリームあります がSourceがSource.actorRefを使用して作成されます。ここでは、アクターは一定の間隔で実行され、連続してメッセージを生成し、ストリームに出力されます。 ProducerをFlowとして添付しました。プロデューサーはProducerMessage.Messageをカフカ

scala apache-kafka akka-stream reactive-kafka 2017-11-11

---

0熱

1答えて

プロデューサーフローをグラフに接続

私はakkaストリームのカフカ（とakkaストリーム全般）を使って新しいです。私は別のトピックにメッセージを公開するためにグラフを作成しようとしています。 処理されたメッセージをコミットするためにプロデューサをフローとしてどのように接続できますか？私はProducer.flowを使用してみましたが、私はあなたがGraphDSLを使用しているため、コンパイラは、前の段階からPassThrough種類

akka-stream reactive-kafka 2017-08-14

---

0熱

1答えて

反応カフカのサブスクリプションに新しくトピックを追加する

iamは私たちのプレイスカラプロジェクトで反応性カフカを開発しました。私たちは5つのトピックを作成しました。これはコンシューマーグループと働き良い人が購読しています。私は 私のコードがある（それが可能である）既存のコンシューマ・グループにこのトピックを追加することができます。 val consumerSettings = ConsumerSettings(system, new ByteArray

akka reactive-kafka 2017-03-22

---

0熱

1答えて

Reactive Kafka：存在しないトピックのストリームを作成中にエラーはありません

最近Reactive Kafkaに切り替えました。トピックのストリームを作成中にトピックが存在する場合、kafkaはエラーをスローしません。それはなぜそうですか？ 私はトピックの存在がAdminUtils.topicExists(zkClient, topicName)で明示的に確認できることを知っています。ストリームを作成する前にトピックがそれ自身で存在するかどうかを確認するために、反応的なカフ

apache-kafka reactive-kafka 2017-05-11

---

2熱

2答えて

Reactive-Kafka：例外的に消費者を一時停止し、要求に応じて再試行する方法

私はすでにGoogleグループに質問しましたが、まだ回答がありませんでした。これをここに投稿すると、別のユーザーになります。 Reactive-Kafkaを使用しています。メッセージの処理中に例外が発生した場合、コンシューマにメッセージを送信しないようにするシナリオを以下に示します。メッセージは、規定された時間後に、または消費者側からの明示的な要求の後に再試行されるべきである。現在のアプローチでは

scala akka-stream reactive-kafka 2017-02-03

---

0熱

1答えて

akkaストリームkafka（reactive-kafka）をakka httpアプリケーションに統合する方法は？

私は基本的なスカラのakka http CRUDアプリケーションを持っています。関連するクラスについては以下を参照してください。 エンティティが作成/更新されるたびに、エンティティIDといくつかのデータ（jsonとして）をKafkaトピックに書き込むだけです。 私はhttp://doc.akka.io/docs/akka-stream-kafka/current/producer.htmlを見てい

scala apache-kafka akka akka-stream reactive-kafka 2017-09-07

---

2熱

1答えて

Bytestringをソースに変換する方法[Bytestring、Any]

私はKafka Reactive StreamsのコンシューマからBytestringとしてファイルを受信して​​います。私はエンティティHttpEntity.DefaultとしてこのBytestringでakka-httpリクエストを構築したいと思います。 HttpEntity.Defaultは、ソース[Bytestring、Any]をそのパラメータの1つとして必要とします。 2つを接続するには

scala akka-stream akka-http reactive-kafka 2016-09-29

---