-
Notifications
You must be signed in to change notification settings - Fork 86
/
connector-test.sh
executable file
·29 lines (22 loc) · 956 Bytes
/
connector-test.sh
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
#!/bin/bash
set -e
confluent local destroy || true
mvn clean package || exit 1
rm -fr $CONFLUENT_HOME/share/confluent-hub-components/confluentinc-kafka-connect-datagen
confluent-hub install --no-prompt target/components/packages/confluentinc-kafka-connect-datagen-*.zip
confluent local services connect start
sleep 10
confluent local services connect status
#connectors="credit_cards stores transactions purchases"
connectors="campaign_finance"
for connector in $connectors; do
confluent local services connect connector config datagen-$connector --config config/connector_${connector}.config
done
confluent local services connect connector status
echo
for connector in $connectors; do
echo
echo $connector:
confluent local services kafka consume $connector --max-messages 10 --property print.key=true --property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer --from-beginning
done
confluent local destroy