3 ms·
Celery Flower TUI doesn't yet support Kafka in Python, though Kombu (the protocol wrapper for celery) does. It looks like Kaskade has non-kombu support for cons
by westurner 2y ago
Celery Flower TUI doesn't yet support Kafka in Python, though Kombu (the protocol wrapper for celery) does. It looks like Kaskade has non-kombu support for consumers and ?
https://github.com/celery/celery/issues/7674#issuecomment-1204053595 https://github.com/celery/celery/issues/7674#issuecomment-12... .. https://news.ycombinator.com/item?id=40842365 https://news.ycombinator.com/item?id=40842365
(Edit)
Kaskade models.py, consumer.py
https://github.com/sauljabin/kaskade/blob/main/kaskade/models.py https://github.com/sauljabin/kaskade/blob/main/kaskade/model...
kombu/transport/confluentkafka.py:
https://github.com/celery/kombu/blob/main/kombu/transport/confluentkafka.py https://github.com/celery/kombu/blob/main/kombu/transport/co...
confluent-kafka-python wraps librdkafka with binary wheels: https://github.com/confluentinc/confluent-kafka-python https://github.com/confluentinc/confluent-kafka-python
librdkafka: https://github.com/edenhill/librdkafka https://github.com/edenhill/librdkafka