You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
We propose adding Kafka support as a broker for Celery, including the following features:
Kafka as a Broker: Enable Celery to use Kafka for message queuing, offering improved scalability and fault tolerance for high-throughput systems. Kombu already has confluentkafka implementation but needs support for interval based commit.
Partition-Based and Topic based Task Listening: Allow Celery workers to listen to specific Kafka partitions, enhancing parallel task processing and load distribution.
Interval-Based Commit: Introduce an interval-based offset commit mechanism, enabling periodic commits for better control and fault tolerance in task processing.
Out-of-Order Commit (Optional): Optionally support out-of-order offset commits, allowing flexibility in task processing order while ensuring proper acknowledgment.
The text was updated successfully, but these errors were encountered:
We propose adding Kafka support as a broker for Celery, including the following features:
Kafka as a Broker: Enable Celery to use Kafka for message queuing, offering improved scalability and fault tolerance for high-throughput systems. Kombu already has confluentkafka implementation but needs support for interval based commit.
Partition-Based and Topic based Task Listening: Allow Celery workers to listen to specific Kafka partitions, enhancing parallel task processing and load distribution.
Interval-Based Commit: Introduce an interval-based offset commit mechanism, enabling periodic commits for better control and fault tolerance in task processing.
Out-of-Order Commit (Optional): Optionally support out-of-order offset commits, allowing flexibility in task processing order while ensuring proper acknowledgment.
The text was updated successfully, but these errors were encountered: