forked from confluentinc/demo-scene
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathconnect_source.sh
executable file
·15 lines (13 loc) · 3.85 KB
/
connect_source.sh
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
#!/usr/bin/env bash
ccloud topic create flood-monitoring-L2404
ccloud topic create flood-monitoring-L2481
ccloud topic create flood-monitoring-059793
ccloud topic create flood-monitoring-3680
# York - River level (1)
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://$CONNECT_HOST_SOURCE:8083/connectors/ -d '{ "name": "source_rest_flood-monitoring-L2404", "config": { "key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.storage.StringConverter", "connector.class": "com.tm.kafka.connect.rest.RestSourceConnector", "tasks.max": "1", "rest.source.poll.interval.ms": "900000", "rest.source.method": "GET", "rest.source.url": "http://environment.data.gov.uk/flood-monitoring/id/stations/L2404", "rest.source.payload.converter.class": "com.tm.kafka.connect.rest.converter.StringPayloadConverter", "rest.source.properties": "Content-Type:application/json,Accept::application/json", "rest.source.topic.selector": "com.tm.kafka.connect.rest.selector.SimpleTopicSelector", "rest.source.destination.topics": "flood-monitoring-L2404" } }'
# York - River level (2)
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://$CONNECT_HOST_SOURCE:8083/connectors/ -d '{ "name": "source_rest_flood-monitoring-L2481", "config": { "key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.storage.StringConverter", "connector.class": "com.tm.kafka.connect.rest.RestSourceConnector", "tasks.max": "1", "rest.source.poll.interval.ms": "900000", "rest.source.method": "GET", "rest.source.url": "http://environment.data.gov.uk/flood-monitoring/id/stations/L2481", "rest.source.payload.converter.class": "com.tm.kafka.connect.rest.converter.StringPayloadConverter", "rest.source.properties": "Content-Type:application/json,Accept::application/json", "rest.source.topic.selector": "com.tm.kafka.connect.rest.selector.SimpleTopicSelector", "rest.source.destination.topics": "flood-monitoring-L2481" } }'
# York - rainfall
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://$CONNECT_HOST_SOURCE:8083/connectors/ -d '{ "name": "source_rest_flood-monitoring-059793", "config": { "key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.storage.StringConverter", "connector.class": "com.tm.kafka.connect.rest.RestSourceConnector", "tasks.max": "1", "rest.source.poll.interval.ms": "900000", "rest.source.method": "GET", "rest.source.url": "http://environment.data.gov.uk/flood-monitoring/id/stations/059793", "rest.source.payload.converter.class": "com.tm.kafka.connect.rest.converter.StringPayloadConverter", "rest.source.properties": "Content-Type:application/json,Accept::application/json", "rest.source.topic.selector": "com.tm.kafka.connect.rest.selector.SimpleTopicSelector", "rest.source.destination.topics": "flood-monitoring-059793" } }'
# Somewhere in the Midlands
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://$CONNECT_HOST_SOURCE:8083/connectors/ -d '{ "name": "source_rest_flood-monitoring-3680", "config": { "key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.storage.StringConverter", "connector.class": "com.tm.kafka.connect.rest.RestSourceConnector", "tasks.max": "1", "rest.source.poll.interval.ms": "900000", "rest.source.method": "GET", "rest.source.url": "http://environment.data.gov.uk/flood-monitoring/id/stations/3680", "rest.source.payload.converter.class": "com.tm.kafka.connect.rest.converter.StringPayloadConverter", "rest.source.properties": "Content-Type:application/json,Accept::application/json", "rest.source.topic.selector": "com.tm.kafka.connect.rest.selector.SimpleTopicSelector", "rest.source.destination.topics": "flood-monitoring-3680" } }'