KafKoi
A very simple, work-in-progress, lightweight ETL framework which reads to and from Kafka.
Using this library
I don't recommend it. This is my first foray into Go.
If you've reviewed the code, find no faults and think it's super awesome, import it.
import "github.com/MickayG/kafkoi"
Example
//Parse the command line arguments (see documentation on method for what they are)
serviceConfig := kafkoi.ParseArgs()
// Here's the logic that will happen between the Kafka topics.
// In this example it just forwards the message on. Resulting in Kafka messages being read from one topic
// and written onto another
passthrough := func(message kafkoi.Message) (kafkoi.Message, bool) {
return message, true
}
// Run KafKoi with the passthrough method and the config passed via command line arguments
kafkoi.Run(passthrough, serviceConfig)