Magnus Edenhill edenhill

edenhill / latest_msg_consumer.py

Last active April 7, 2020 16:50

Start consumer at latest message

	#!/usr/bin/env python

	from confluent_kafka import Consumer, KafkaException, KafkaError, OFFSET_END
	import sys

	if __name__ == '__main__':

	broker = "localhost:51895"
	topics = ["test"]
	group = "mygroup"