Metriche repository
- Star
- (1114 star)
- Metriche merge PR
- (Nessuna PR mergiata in 30 g)
Descrizione
I would like to use pykafka to connect to IBM Bluemix Message Hub with is a Kafka implementation. There is a kafka-python example in this thread. https://stackoverflow.com/questions/35294949/can-i-call-the-bluemix-message-hub-service-from-python/40325181#40325181
I also found this for confluent-kafka:
A new Python client
Confluent, the company founded by the creators of Kafka, has released a Python client (https://github.com/confluentinc/confluent-kafka-python). It is built as a thin bindings layer on top of librdkafka and works for both Python 2 and 3.
To use with Message Hub, simply pass these properties in when creating a Producer/Consumer:
'ssl.ca.location': '/etc/ssl/certs/',
'sasl.mechanisms': 'PLAIN',
'sasl.username': '<USER>',
'sasl.password': '<PASSWORD>',
'security.protocol': 'sasl_ssl'
Note: The value of ‘ssl.ca.location depends’ on your operating system. For example:
Ubuntu: /etc/ssl/certs/
RedHat: /etc/pki/tls/cert.pem
OS X: select system root certificates from Keychain Access and export as .pem on the filesystem.
Is there a way to connect using pykafka? If so, how would I do it?