easy sugar

Hi. It would be nice to have something like `ProcessCollector`. Using `ProcessCollector` from [prometheus_client](https://github.com/prometheus/client_python) raises an error: ``` Traceback (most recent call last): File "prom.py", line 5, in prometheus_service.register(ProcessCollector(namespace='mydaemon')) File...

Stop consumer raises CancelledError

2

Hello. I am using kafka consumer only for getting partitions for topic. And after that, I try to close consumer, but got CancelledError. It seems, that it might be some...

Kafka producer lost headers for message

2

Sometimes AIOKafkaProducer writes messages without headers. Environment: - python version `3.7.4` - aiokafka version `0.5.2` - kafka-python version `1.4.6` - docker image `confluentinc/cp-kafka:5.2.1` In new environment I created a new...