ポート8083で、http:// localhost:8083でGUIを取得しているInfluxdbを実行しています。
今kafkaに来てください、ここで私はhttps://kafka.apache.org/quickstartに従ってセットアップを参照しています
次のコマンドで、フォルダー/opt/zookeeper-3.4.10にあるzookeeeperを起動します。 bin/zkServer.sh start
そのため、zookeeperが開始され、/ opt /kafka_2.11-1.1.0フォルダーの下のkafkaが次のように開始されます。
bin/kafka-server-start.sh config/server.properties
単一のパーティションと1つのレプリカのみを使用して「test」という名前のトピックを作成します。
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
トピックが作成され、コマンドでチェックインできます:
bin/kafka-topics.sh --list --zookeeper localhost:2181
ここまではすべてがうまく調整されています。
次に、「Kafkaconnect」コンポーネントを使用してデータをインポート/エクスポートする必要があります。したがって、シードデータを次のように作成しています。echo -e "foo\nbar" > test.txt
「kafkaconnect」のコネクタ構成を使用して機能するようになりました:bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties
上記のコマンドを実行した後、私は得ています: Address already in use
Kafka connect has stopped
私も変更しrest.port=8084
、それはすでに8083にまだ私は同じを取得していますinfluxdbとの競合を取得しないように/opt/kafka_2.11-1.1.0/config/connect-distributed.propertiesでAddress already in use
、Kafka connect has stopped
スクリーンショットに示すように、 。
スタンドアロンモードでKafkaConnectを使用しているため、次の場所でRESTポートを変更する必要がありますconfig/connect-standalone.properties
。
rest.port=18083
スタンドアロンと分散の詳細については、こちらのドキュメントをご覧ください。
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加