apache-kafka

2熱

2答えて

私はSpring Kafkaを初めて使用しています。私のコンシューマーコードでAcknowledgement.acknowledge（）メソッドを手動コミットに使用できません。私の消費者の構成やリスナーコードに欠けていることがあれば教えてください。そうでなければ、条件に基づいて肯定応答オフセットを処理する別の方法があります。ここで私は、オフセットがコミットされていない/手動で肯定応答しない場合、

-2熱

1答えて

kafkaメッセージング・システムを使用したoracleデータベースの問合せ

データ・ウェアハウスであるoracleデータベースがあり、私のシステムでメッセージを交換するためにkafkaメッセージング・システムを使用しています。私の災害復旧ソリューションでは、kafka connectを使用してOracleデータベースでクエリを実行し、クエリされたメッセージをH2データベースにコピーします。カフカ接続を使用してOracleデータベースで照会するソリューションはありますか？私

0熱

1答えて

春のカフカ、TCPポートをプロデューサーとして

私はカフカとストリーミングを使い慣れていますので、私に同行してください。私は動物園とカフカの両方を正常にインストールして起動しました。シンプルなトピックを作成し、そのトピックに送信されているものをコンソールでリッスンして表示するコンソールコンシューマを開始しました。プロデューサは現在、エンドポイント呼び出しの結果として情報を送信します。私はNMEA形式のデータをTCPポートに送信するデバイス

1熱

2答えて

カフカドッカー、ドッキングウィンドウ-のmaven-pluginの、春ブーツ

https://github.com/fabric8io/docker-maven-plugin 私は、次のMavenの画像を使用します。https://hub.docker.com/r/wurstmeister/kafka/ は、これは私のMavenの設定です： <plugin> <groupId>io.fabric8</groupId> <artifactId>docker

2熱

1答えて

mongoDB＆Spark： "com.mongodb.MongoSocketReadException：途中でストリームの最後に到達しました"

私は、カフカのavroメッセージストリームを処理し、各メッセージに対してmongoDBコレクションのクエリを実行します。数十件のメッセージが正しく処理された後、アプリケーションは実行を停止し、「com.mongodb.MongoSocketReadException：途中で終了しました」というメッセージがスローされます。 JavaPairInputDStream<String, byte[]>

2熱

1答えて

スプリングブートJavaカフカ設定、上書きポート

私はSpring Boot + Kafkaを使用しています。、9092 今私は、ポートを変更する必要があります。この設定はかなり正常に動作し、デフォルトカフカポートにカフカのインスタンスに接続することができます @Configuration @EnableKafka public class KafkaConfig { } ：これはカフカのための私の現在、非常に単純な構成であります9

0熱

1答えて

Kafka Streams JoinWindowのデータ

Kafka Streamsでは、私はJoinWindowを使用してストリーム/ストリーム結合を使用しています。私が理解できるところでは、JoinWindowsはStoresを使用して実装され、その後両方のストリームのデータはRocksDBデータベースに格納されます。しかし、イベント時間が終了すると（で定義された保存期間を（）まで過ぎたら、物理データはどうなりますか？それらはRocksDBデータ

0熱

2答えて

Ubuntuでコンフルエントを開始する際にエラーが発生しました。コンフルエントにカールが必要

コンフルエント3.3.1をUbuntu 16.04LTSにインストールしました。私はドキュメントに従ってコンフルエントにインストールするためにすべての指示に従った。しかし、私がコンフルエントな "コンフルエントなスタート"を使用して開始するとき。私はエラーが発生している '合流'は 'カール'が必要です。この問題を解決するにはどうすればよいですか。私は自分のシステムにJava8とScala 2.1

0熱

1答えて

マイクロサービス間の通信のためにRestの代わりにKafka

（マイクロ）サービス間の通信をRESTからKafkaに変更したいと考えています。私はその話題については不明であり、そのことに関するいくつかの意見を聞きたいと思っていました。次の設定を検討してください。 Webアプリケーション用のRESTを介してCRUD機能を提供するAPIゲートウェイがあります。だから私はユーザーが呼び出すことができる4つのエンドポイントがあります。 APIゲートウェイは要求を