Example Kafka Source Connector

This project contains the source code for a custom API and Source Connector. The RandomLong API has a single endpoint that provides a random Long value. The Source Connector periodically calls the endpoint to produce the random Long value to a Kafka topic.

Getting Started

Clone repo:

git clone [email protected]:enfuse/kafka-connect.git

Compile and package docker image:

$ cd kafka-connect
$ ./gradlew clean build docker

Create Source Connector uber-jar:

$ cd kafka-connect
$ ./gradlew clean shadowJar

• Tutorial Blog Post
• Use Google Kubernetes Engine
• Use Minikube On Local Machine
• How to Install and Run a Custom Connector
• Helpful Links
• Helpful Kafka Commands
• Push API Image to Google Registry and Deploy on GKE