Hi All, I am pushing data from nodejs server to kafka topic when i consume this topic getting null values. i have checked javascript producer its working fine and send data Json data to kafka. any help would be appreciated. i have posted my producer code here.
var kafka = require('kafka-node'); var client = new kafka.Client('localhost:2181'); var HighLevelProducer = kafka.HighLevelProducer; var producer = new kafka.HighLevelProducer(client); var KeyedMessage = kafka.KeyedMessage; var topicName = 'test1'; const buffer = new Buffer.from(JSON.stringify(data)); // i am getting data from source in data variable. console.log('get into postdata'); payloads = [{topic:topicName, message:buffer}]; console.log('kafka producer is connected and ready.'); producer.send(payloads, function(error, result) { console.info('Sent payload to Kafka: ', payloads); if (error) { console.error(error); } else { console.log('result: ', result) } }); here is node server logs: data arrived get into postdata kafka producer is connected and ready. Sent payload to Kafka: [ { topic: 'test1', message: <Buffer 7b 22 41 6c 74 65 72 6e 61 74 65 55 6e 69 71 75 65 4b 65 79 22 3a 22 22 2c 22 44 6f 77 6e 6c 6f 61 64 65 64 44 65 76 69 63 65 55 6e 69 71 75 65 4b 65 ... 1564 more bytes>, partition: 0, attributes: 0 } ] result: { test1: { '0': 33 } }