apache-kafka

0熱

1答えて

kafkaサーバーを起動するために過去10時間試しましたが、できませんでした。私は飼育係をインストールし、win10上でそれを実行するために管理が、私は classpath is empty. please build the project first e.g. by running 'gradlew jarall' エラーが発生しました。私はubuntuとjre 9をインストールしま

0熱

1答えて

nagiosを使ってapache kafkaを監視するには？

nagiosを使用してカフカクラスタを監視する方法はありますか？ブローカステータス、パーティションステータス、メモリステータス、現在のオフセット、およびクラスタからのすべての貴重なメトリックを確認する必要があります。

0熱

1答えて

KafkaクライアントIDプロパティ（春のクラウドストリームの場合）

Spring Cloud Streamの場合、KafkaクライアントIDプロパティを設定する方法はありますか？当然私はカフカバインダーを使用しています。これを設定する私のサービスのいくつかは複製されるので、インスタンス間でIDを一意にする方法はありますか？（Spring Kafka Consumer Client-Id configurationを見ると、IDは一意である必要があるように見えます

-1熱

1答えて

java.lang.ClassNotFoundException：com.datastax.spark.connector.japi.rdd.CassandraTableScanJavaRDD

私はcassandraと一緒にKafka Spark Streamingを使用しています。 Eclipseを使用してJavaクラスを実行しているときは正常に動作しますが、mavenを使用してビルドしてSpark Shellで実行すると、前述の例外がスローされます。 java.lang.NoClassDefFoundError: com/datastax/spark/connector/japi/r

0熱

1答えて

Kafka - このサーバーはそのトピックのリーダーではありません - パーティション

私は2つのブローカーkafka 0.10.2.0クラスターを持っています。再構成係数は2です。このKafkaに対して1.0.0 kafkaストリームアプリケーションを実行しています。私のカフカストリームアプリケーションでは、プロデューサの設定はretries = 10 and retry.backoff.ms = 100 数分実行した後、私はKakfa server.logの次のログを観察しました

1熱

2答えて

NoClassDefFoundError FlipとKafkaを統合しようとしています

私はkafkaとflinkをinteregateしようとしています。アイデアは、カフカ・キューを消費し、フリンクを使用してデータを変換することです。私は https://github.com/abhishek-ch/evolveML/blob/master/flink/kafka-flink-example/pom.xml これらは私の依存関係している下記の例に次のようです。 <dependen

0熱

1答えて

@ KafkaListenerのメタ注釈を作成する

@KafkaListenerアノテーションに基づいてカスタムメタアノテーションを作成しようとしていますが、spring-kafkaがエラーをスローします。ここでは私の注釈です： @Target({ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE}) @Retention(RetentionPolicy.RUNTI