Simplify implementation
Simplify implementation

wvanbergen/kafka,ORBAT/kafka,topfreegames/kafka,saleswise/kafka,kmiku7/kafka,bhirbec/kafka,gcnonato/kafka,winlinvip/kafka-1,xlvector/kafka,clessor/kafka,skyportsystems/kafka-2,datajet-io/kafka,ChannelMeter/kafka,yejingx/kafka