Please make sure to update your Python dependencies before using this version (pip install -r requirements.txt
).
- Add support for
kafka-python
>= 1.4.5 - Consider -1 value for
partitions
andreplica_factor
but display a warning when topic already exists - Add new
kafka_info
lib to get information about Kafka cluster (topics, brokers, consumer groups), see documentation on how to use it - Add support for SASL SCRAM authentication mechanism, MVP @LaurentOliva
- Replace Travis with Github Actions, MVP @ryarnyah