Remove old schemes from Confluent Schema Registry

delete_old_schemas.py

#!/usr/bin/env python
# Cleanup old schemas from schema registry

import httplib
import json
import re

DELETE_REGEX = 'IT6[0-6][0-9]-'

con = httplib.HTTPConnection('127.0.0.1', 8081)
con.request('GET', '/subjects')
rsp = con.getresponse()
subjects = json.loads(rsp.read())
con.close()

for subj in subjects:
    if re.search(DELETE_REGEX, subj):
        con = httplib.HTTPConnection('127.0.0.1', 8081)
        con.request('DELETE', '/subjects/%s' % subj)
        rsp = con.getresponse()
        print 'Delete %s status %d' % (subj, rsp.status)
        con.close()