simple kafka commit to simulate bulk commit using confluence kafka
u can simulate produce and consume message with this code.
producer :
go run main.go -type=producer -publishCount=<number of message to publish>consumer :
go run main.go -type=consumer -worker=<number of worker to do concurrent processing>