Golang batch processing with flush out within a time limit
Recently, my team was building the Kafka streaming consumers and using python Faust framework…