SHARE
TWEET

Untitled

a guest Oct 21st, 2019 90 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. const kafka = require('kafka-node')
  2.  
  3. const consumer = new kafka.ConsumerGroupStream({
  4.     kafkaHost: '172.28.128.3:9092',
  5.     groupId: 'TestGroup2',
  6.     fromOffset: 'earliest'
  7. }, 'testtopic2')
  8.  
  9. consumer.on('data', message => {
  10.     console.log(message)
  11. })
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top