const kafka = require('kafka-node')

const consumer = new kafka.ConsumerGroupStream({
    kafkaHost: '172.28.128.3:9092',
    groupId: 'TestGroup2',
    fromOffset: 'earliest'
}, 'testtopic2')

consumer.on('data', message => {
    console.log(message)
})