apache-kafka

0熱

1答えて

コンピュータからphp7.dllが見つからないため、プログラムを起動できません

現在のxamppにapache kafkaをインストールしています。 hereはインストールリンクです。私はphp.iniファイルetcディレクトリにextension=php_rdkafka.dllを入れました。 xamppが再起動している間に私はこのエラーメッセージを受けましたThe program can't start because php7.dll is missing from yo

php dll apache-kafka 2017-12-01

---

0熱

1答えて

私はMS SQLでのいくつかのテーブルを持っている

Nifi/HDFを使用してMS SQLからデルタレコードを読み取るためにどのように、これらのテーブルは、毎秒更新を選択し、内側を想定してみましょう多かれ少なかれ見て、この SELECT G_ID,UpdateTime,ID,Name,T_NAME FROM TABLE1 AS table1 INNER JOIN TABLE2 AS table2 ON table1.IP=table2.ID WH

sql-server hadoop apache-kafka apache-nifi hdf 2017-12-01

---

3熱

2答えて

カフカストリーミングアプリケーションをKafkaクラスタに展開する方法

私はKafkaストリーミングアプリケーションを作成しました。私はKafkaクラスタに展開したいと思います。だから私は、jarファイルを構築し、コマンドを使用して、それを実行します。 java -jar KafkaProcessing-1.0-SNAPSHOT-jar-with-dependencies.jar testTopic kafka1:9092,kafka2:9092 zookeeper1

apache-kafka apache-kafka-streams 2017-12-01

---

0熱

1答えて

kafkaクラスターがダウンした後に@KafkaListenerが無限ループに入ります

私は3ノードのkafkaクラスターを持っています。私はdebezium（kafka-mysqlコネクター）を使用しています。 トピックコンシューマとして@KafkaListenerというメソッドを記述します。 その後、手動でkafkaクラスタをシャットダウンします（kill -15）。 その後、リスナーは突然無限ループに陥ります。 topコマンド jstack と消費者のログ（無限） これはバグで

java spring apache-kafka spring-kafka 2017-12-02

---

0熱

1答えて

RESTからメッセージキュー

への通信方法REST Microserviceは、ハイブリッドである別のMicroserviceと通信することができます。つまり、RESTとMessage Queueと通信できます。 APIゲートウェイの例。外の世界では、彼はREST経由でApp、Mobilephoneと通信することができますが、バックエンドからの通信はメッセージキュー経由です。 使用例： 私のホームページはデータベースから車両を

spring rest apache-kafka message-queue microservices 2017-12-02

---

1熱

1答えて

カフカ

念のために、私たちは /usr/hdp/current/kafka-broker/bin/kafka-topics.sh --zookeeper hdpmaster01:2181 --delete --topic gtom.poli.pri.proc Topic gtom.poli.pri.proc is already marked for deletion トピックとして間違ったトピッ

apache-kafka apache-zookeeper 2017-12-03

---

0熱

1答えて

Lagomパブリッシュメッセージ（カフカ付き）

公開方法は1つだけですhere。 別の方法がありますか？ この例では、persistentEntityRegistryを使用せずに動的トピックIDとカスタムイベントを使用してパブリケーションを作成する必要がありますか？ eventIdでイベントを公開するにはどうすればよいですか？ @Override default Descriptor descriptor() { retur

java apache-kafka publish-subscribe lagom 2017-12-04

---

0熱

1答えて

Spring Cloud Streamを使用してConfluent Schema Registryを使用してAvroメッセージを生成および使用する方法は？

私は、Start Streaming with Kafka and Spring Cloudに従うことによって例を実行できますが、残念なことにコンフルエントなスキーマレジストリは使用しません。私はSpring Cloud Stream reference guideのコンフルエントスキーマレジストリ部分を読んだが、コンフルエントな3.0.0ではうまく動作せず、コンフルエントなスキーマレジストリを使

apache-kafka registry schema spring-cloud-stream confluent 2017-12-04

---

0熱

1答えて

KStreamの互換​​性のないタイプ

文字列を使用してコード部分で何かを試していましたが、以下のコードを思いついたので、コードの構文上の問題を助けてください。二KStream文で KStreamBuilder builder = new KStreamBuilder(); KStream<String, String> textlines = builder.stream("INTOPIC"); KStream<String, S

apache-kafka apache-kafka-streams 2017-12-05

---