Şöyle yaparız
docker pull confluentinc/cp-kafka-connect:latestdocker run \-it \--rm \--name es-sink-connector \-e CONNECT_BOOTSTRAP_SERVERS=kafka:9092 \-e CONNECT_REST_PORT=8083 \-e CONNECT_GROUP_ID="connect-cluster" \-e CONNECT_CONFIG_STORAGE_TOPIC="connect-configs" \-e CONNECT_OFFSET_STORAGE_TOPIC="connect-offsets" \-e CONNECT_STATUS_STORAGE_TOPIC="connect-status" \-e CONNECT_KEY_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \-e CONNECT_VALUE_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \-e CONNECT_INTERNAL_KEY_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \-e CONNECT_INTERNAL_VALUE_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \-e CONNECT_REST_ADVERTISED_HOST_NAME="localhost" \-e CONNECT_PLUGIN_PATH="/usr/share/java,/etc/kafka-connect/jars" \-p 8083:8083confluentinc/cp-kafka-connect:latest
No comments:
Post a Comment