Commit b7e42fab authored by Ignacio's avatar Ignacio
Browse files

Merge branch 'dev' into 'master'

Cambia connector de AIS para nueva DB

See merge request redmic-project/confluent/confluent-platform!12
parents 653bd124 3086efad
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -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://db:5432/redmic?currentSchema=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\": \"tracking\", \"auto.evolve\": \"true\", \"insert.mode\": \"upsert\", \"pk.mode\": \"record_value\", \"pk.fields\": \"mmsi\"}}" \
				"http://${addr}/connectors" >& /dev/null

			break