Loading scripts/docker-entrypoint.sh +1 −1 Original line number Diff line number Diff line Loading @@ -19,7 +19,7 @@ while [[ "${done}" = false ]]; do echo "Connected, creating connectors at host: ${addr}" curl -s -X POST -H "Content-Type: application/json" --data \ "{\"name\": \"jdbc-sink\", \"config\": {\"name\":\"jdbc-sink\", \"connector.class\":\"io.confluent.connect.jdbc.JdbcSinkConnector\", \"tasks.max\":\"1\", \"topics\":\"realtime.tracking.vessels\", \"connection.url\": \"jdbc:postgresql://ais-db:5432/ais\", \"connection.password\": \"${POSTGRES_PASS}\", \"connection.user\": \"${POSTGRES_USER}\", \"table.name.format\": \"tracking\", \"auto.evolve\": \"true\", \"insert.mode\": \"upsert\", \"pk.mode\": \"record_value\", \"pk.fields\": \"mmsi\"}}" \ "{\"name\": \"jdbc-sink\", \"config\": {\"name\":\"jdbc-sink\", \"connector.class\":\"io.confluent.connect.jdbc.JdbcSinkConnector\", \"tasks.max\":\"1\", \"topics\":\"realtime.tracking.vessels\", \"connection.url\": \"jdbc:postgresql://ais-db:5432/ais\", \"connection.password\": \"${POSTGRES_PASS}\", \"connection.user\": \"${POSTGRES_USER}\", \"table.name.format\": \"last_position\", \"auto.evolve\": \"true\", \"insert.mode\": \"upsert\", \"pk.mode\": \"record_value\", \"pk.fields\": \"mmsi\"}}" \ "http://${addr}/connectors" >& /dev/null break Loading Loading
scripts/docker-entrypoint.sh +1 −1 Original line number Diff line number Diff line Loading @@ -19,7 +19,7 @@ while [[ "${done}" = false ]]; do echo "Connected, creating connectors at host: ${addr}" curl -s -X POST -H "Content-Type: application/json" --data \ "{\"name\": \"jdbc-sink\", \"config\": {\"name\":\"jdbc-sink\", \"connector.class\":\"io.confluent.connect.jdbc.JdbcSinkConnector\", \"tasks.max\":\"1\", \"topics\":\"realtime.tracking.vessels\", \"connection.url\": \"jdbc:postgresql://ais-db:5432/ais\", \"connection.password\": \"${POSTGRES_PASS}\", \"connection.user\": \"${POSTGRES_USER}\", \"table.name.format\": \"tracking\", \"auto.evolve\": \"true\", \"insert.mode\": \"upsert\", \"pk.mode\": \"record_value\", \"pk.fields\": \"mmsi\"}}" \ "{\"name\": \"jdbc-sink\", \"config\": {\"name\":\"jdbc-sink\", \"connector.class\":\"io.confluent.connect.jdbc.JdbcSinkConnector\", \"tasks.max\":\"1\", \"topics\":\"realtime.tracking.vessels\", \"connection.url\": \"jdbc:postgresql://ais-db:5432/ais\", \"connection.password\": \"${POSTGRES_PASS}\", \"connection.user\": \"${POSTGRES_USER}\", \"table.name.format\": \"last_position\", \"auto.evolve\": \"true\", \"insert.mode\": \"upsert\", \"pk.mode\": \"record_value\", \"pk.fields\": \"mmsi\"}}" \ "http://${addr}/connectors" >& /dev/null break Loading