connect-standalone komutu - Kafka Connect İçin Connector'ları Başlatır

Giriş

Birinci parametre Kafka Connect cluster için gerekli ayarları içerir

İkinci parametre çalıştırılacak connector için gerekli ayarları içerir

Örnek

Şöyle yaparız

bin/connect-standalone.sh \
  config/connect-standalone.properties \
  config/mongo-source.properties

Örnek

Şöyle yaparız

bin/connect-standalone.sh \
  config/connect-standalone.properties \
  config/mysql-connector.properties

connect-standalone.properties Dosyası

Örnek

Şöyle yaparız

# from more information, visit: http://docs.confluent.io/3.2.0/connect/userguide.html#common-worker-configs
bootstrap.servers=127.0.0.1:9092
key.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=false
value.converter=org.apache.kafka.connect.json.JsonConverter
value.converter.schemas.enable=false
# we always leave the internal key to JsonConverter
internal.key.converter=org.apache.kafka.connect.json.JsonConverter
internal.key.converter.schemas.enable=false
internal.value.converter=org.apache.kafka.connect.json.JsonConverter
internal.value.converter.schemas.enable=false
# Rest API
rest.port=8083
rest.host.name=127.0.0.1
#specify listeners
#listeners=http://127.0.0.1:8080,http://127.0.0.1:8443
# this config is only for standalone workers
offset.storage.file.filename=standalone.offsets
offset.flush.interval.ms=10000