I am consuming data using group consumer in node js & kafka server needs certificate to pass .So i am passing certificate but not consuming data & even not getting error also.
I am sharing code here
const consumer = new kafka.GroupConsumer({
groupId: 'abc123',
connectionString: msgSystemConnectionString,
ssl: {
cert: "./src/config/ssl/kafkacert.pem",
key: "./src/config/ssl/kafkakey.key",
passphrase: '123'
}
});
Note:Same certificate using for producer it's working fine.
Hi ,
I am consuming data using group consumer in node js & kafka server needs certificate to pass .So i am passing certificate but not consuming data & even not getting error also.
I am sharing code here const consumer = new kafka.GroupConsumer({ groupId: 'abc123', connectionString: msgSystemConnectionString, ssl: { cert: "./src/config/ssl/kafkacert.pem", key: "./src/config/ssl/kafkakey.key",
passphrase: '123' } });
Note:Same certificate using for producer it's working fine.