Pause or resume all connectors on a Kafka Connect cluster

pause_connectors.py

#!/usr/bin/env python

CONNECT_ENDPOINT = 'http://10.0.0.24:8083'

import httplib
import json
import os
import sys

action = 'pause' if os.path.basename(sys.argv[0]).startswith('pause') else 'resume'
addr = CONNECT_ENDPOINT.split('//')[1]

req = httplib.HTTPConnection(addr)
req.request('GET', '/connectors', headers = {'Accept': 'application/json'})
conns = json.loads(req.getresponse().read())

for conn in conns:
    req = httplib.HTTPConnection(addr)
    url = '/connectors/%s/%s' % (conn, action)
    req.request('PUT', url)
    print '%s: %d' % (url, req.getresponse().status)