Repository navigation
- upgrade kafka-go plugin to v0.4.47 version;
- add PushWithKV function, customize Key value;
- change startProducers function:
q.channel <- msg
to
select {
case q.channel <- msg:
fmt.Println("kafka channel message send successfully.")
}