kafka

do consume through specified kafka addresses, topics, group and wait time.

process kafka message.

do produce through specified kafka addresses, topic and content.

kafka consumer struct.

kafka message processor.