kafka-consumer-api

0熱

2答えて

スカラマニフェストが見つからないSpark Streaming

Spark Streamingの新機能、 Spark StreamingからKafkaUtilsを使用してKafkaへの直接ストリームを作成しました。ここで Exception in thread "main" java.lang.NoClassDefFoundError: scala/reflect/ClassManifest at kafka.utils.Log4jController$.(L

java maven spark-streaming kafka-consumer-api 2017-11-15

---

0熱

1答えて

Kafkaのオフライン管理とローカルデータベース

私はカフカのトピックとデータベースのオフセットを管理したいので、ある時点後にキューで再処理したいと思っています。これをどうやって進めることができますか？前もって感謝します。

java apache-kafka kafka-consumer-api spring-kafka 2017-11-16

---

0熱

1答えて

restコントローラがspring kafka経由でkafkaのレコードを返す

私のデモアプリケーションでは、メッセージをkafkaキューに戻すためにrestコントローラを作成する必要があります。私は春・カフカのリファレンスガイドを読んで、消費者の設定を実装し、作成した豆を @Configuration @EnableKafka public class ConsumerConfiguration { @Value("${kafka.bootstrap-ser

spring-boot apache-kafka kafka-consumer-api spring-kafka spring-web 2017-11-20

---

0熱

1答えて

1つのパーティションでカフカトピックの同時メッセージリスナーを作成する方法

Uusing Spring Kafka org.springframework.kafka.listener.ConcurrentMessageListenerContainerは、トピック内のパーティション数とContainerPropertiesに基づいて複数のリスナーを作成します。 javadocには、「同じパーティション内のメッセージは順次処理されます」と表示されます。したがって、パーティ

apache-kafka kafka-consumer-api spring-kafka 2017-11-21

---

0熱

1答えて

kafkaマルチノードセットアップアクティブ - アクティブ

私はkafkaを初めて使い、いくつかの基本的な疑問があります。 私はマルチノードカフカをセットアップしようとしていました（Active-Active）。ここでのシナリオは次のとおりです。 - 単一のZooKeeperを実行している（ポート：2181） が開始3カフカブローカー（9092,9093,9094） 単一のトピックのテストを作成します（パーティション：1、複製3） ブローカーリスト（909

java apache-kafka kafka-consumer-api 2017-11-24

---

0熱

1答えて

どのようにカフカがコンシューマーオフセットをコミットしましたか？

私はカフカストリームアプリケーションを持っています。私のアプリケーションがイベントを正常に処理しています。 イベントを再処理/スキップするために必要なオフセットを使用して、カフカコミット済消費者オフセットを変更する方法。私はHow to change start offset for topic?を試しました。しかし、私は 'Node does not exist：'というエラーが出ます。私を助け

apache-kafka apache-zookeeper kafka-consumer-api apache-kafka-streams 2017-11-24

---

4熱

1答えて

Apache Flink：カフカのデータをバイト配列として読み取る

byte[]形式のカフカからデータを読み取るにはどうすればよいですか？ SimpleStringSchema()でイベントを読み取る実装がありますが、データを読み取るスキーマがbyte[]で見つかりませんでした。ここで は私のコードです： Properties properties = new Properties(); properties.setProperty("bootstrap

deserialization apache-flink kafka-consumer-api flink-streaming 2017-11-26

---

1熱

1答えて

Kafkaでの操作を求める

私はKafkaでいくつかの管理作業を行うシナリオを持っています。 トピックAには10個のパーティションがあります。トピックAからのメッセージを消費する5つの異なるアプリケーションがあり、各アプリケーション（app1、app2、app3、app4、app5）には独自のコンシューマ "group.id"（group1、group2、group3、group4、group5）があります。独自のオフセット

apache-kafka kafka-consumer-api 2017-11-28

---

1熱

1答えて

カフカの_transaction_stateトピックからデータを読み取る0.11.0.1

特定のトランザクションIDのトランザクションがコミットされたかどうかを知るために、トランザクションのメタデータ（Kafka 0.11.0.1でサポートされている）を読みたいない。現在、_transactional_stateトピックからキーと値を取得していますが、エンコードされた形式です。 キー= 10000000mmm、値= ���� + '）あなたはTransactionLogMessageP

apache-kafka kafka-consumer-api messagebroker string-decoding 2017-12-06

---