Skip to content

Latest commit

 

History

History
25 lines (24 loc) · 1.04 KB

usecase_finserv_3.md

File metadata and controls

25 lines (24 loc) · 1.04 KB
Raw

Create datagen connector for Stocktrades

We have an avro schema in datagen/ for stocks. In this lab we will create datagen conenctor for this. You can use datagen connector to generate your own data. check the schema script first

cast confluent-ksqldb-hands-on-workshop/docker/datagen/stocks_service.avro

Create the connector:

curl -s -X PUT -H  "Content-Type:application/json" http://localhost:8083/connectors/source-stocktrades/config \
-d '{"connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
     "key.converter": "org.apache.kafka.connect.storage.StringConverter",
     "kafka.topic": "stocktrades",
     "max.interval": 1000,
     "schema.filename": "/datagen/stocks_service.avro",
     "schema.keyfield": "userid"
          }'

check now in Control Center and play aournd in KSQL (in cli or in Control Center)

docker exec -it workshop-ksqldb-cli ksql http://ksqldb-server:8088
ksql> print 'stocktrades' from beginning;

End Lab 3

go back to Agenda