Data Lake for Enterprises

Consumer - getting messages from Kafka

The default consumer configuration ($KAFKA_HOME/config/consumer.properties) that comes bundled with Kafka is as shown:

# Zookeeper connection string# comma separated host:port pairs, each corresponding to a zk# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002"zookeeper.connect=127.0.0.1:2181# timeout in ms for connecting to zookeeperzookeeper.connection.timeout.ms=6000#consumer group idgroup.id=test-consumer-group#consumer timeout#consumer.timeout.ms=5000

Code 04: Console Consumer Configuration

As seen here, the only configuration required by the console consumer (the consumer that comes by default with Kafka for terminal/ssh based consumption) is the Zookeeper connection (this is an old ...