#fetch flag
from kafka import KafkaConsumer
con = KafkaConsumer('flag',bootstrap_servers='192.184.57.3:9092',
security_protocol="SASL_PLAINTEXT", sasl_mechanism='PLAIN', sasl_plain_username='bob',sasl_plain_password='shadow1')
for msg in con:
	print(msg)