A Kafka consumer for listing available schema versions

schema-versions.py

#
# A Kafka consumer, that will print schema version information for
# all available subjects.
#
# Use the RESTful API to query SchemaRegistry directly. For example:
# curl http://schema-registry:8081/subjects/{subject}/versions
#
from kafka import KafkaConsumer
from random import randint

import json

def decode_message (msg): 
 if msg:
   return json.loads(msg.decode('utf8'))
 else:
   return None
   
consumer = KafkaConsumer(bootstrap_servers='kafka:9092', group_id='schema-version-list-'+str(randint(0,1000)), request_timeout_ms=5000, session_timeout_ms=10000, auto_offset_reset='earliest', value_deserializer=decode_message)
consumer.subscribe(['_schemas'])

for msg in consumer:
  key = msg.key
  val = msg.value
  print "subject=", val['subject'], " version=", val['version']