项目作者: ivangfr

项目描述 :
The main goal is to play with Kafka Connect and Streams. We have store-api that inserts/updates records in MySQL; Source connectors that monitor inserted/updated records in MySQL and push messages related to those changes to Kafka; Sink connectors that read messages from Kafka and insert documents in ES; Store-streams that listens for messages in Kafka, treats them using Kafka Streams and push new messages back to Kafka.
高级语言: Java
项目地址: git://github.com/ivangfr/springboot-kafka-connect-jdbc-streams.git