/testing-neo4j-kafka-connect

Primary LanguageShell

TESTING-NEO4J-KAFKA-CONNECT

  1. run docker-compose up
docker-compose up -d
  1. register neo4j source connector
./register-source-neo4j-connector.sh
  1. generate test data
./gen-data.sh
  1. show messages
./consume-neo4j-topic.sh neo4j-source
  1. add test data
./gen-data.sh

Appendix

consume offset

./consume-neo4j-topic.sh _neo4j-connect-offsets

list topics

./list-topics.sh