The Fix
Fixes an invalid configuration key in the Kafka broker demo, changing 'bootstrap_servers' to 'bootstrap.servers'.
Based on closed celery/celery issue #10011 · PR/commit linked
Production note: This usually shows up under retries/timeouts. Treat it as a side-effect risk until you can verify behavior with a canary + real traffic.
@@ -41,7 +41,7 @@ For celeryconfig.py:
"security.protocol": "SASL_SSL",
"sasl.mechanism": "SCRAM-SHA-512",
- "bootstrap_servers": "broker:9094",
+ "bootstrap.servers": "broker:9094",
}
Option A — Apply the official fix\nFixes an invalid configuration key in the Kafka broker demo, changing 'bootstrap_servers' to 'bootstrap.servers'.\nWhen NOT to use: Do not apply this fix if using a different Kafka client that supports 'bootstrap_servers'.\n\n
Why This Fix Works in Production
- Trigger: cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "bootstrap_servers""}
- Mechanism: Fixes an invalid configuration key in the Kafka broker demo, changing 'bootstrap_servers' to 'bootstrap.servers'.
- If left unfixed, the same config can fail only in production (env differences), causing startup failures or partial feature outages.
Why This Breaks in Prod
- Surfaces as: cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "bootstrap_servers""}
Proof / Evidence
- GitHub issue: #10011
- Fix PR: https://github.com/celery/celery/pull/10060
- Reproduced locally: No (not executed)
- Last verified: 2026-02-08
- Confidence: 0.70
- Did this fix it?: Yes (upstream fix exists)
- Own content ratio: 0.72
Discussion
High-signal excerpts from the issue thread (symptoms, repros, edge-cases).
“<!-- Please fill this template entirely and do not erase parts of it. We reserve the right to close without a response bug reports which are incomplete. --> # Checklist <!-- To check an item on the list replace [ ] with [x]. --> - [ ] I hav”
Failure Signature (Search String)
- cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "bootstrap_servers""}
Error Message
Stack trace
Error Message
-------------
cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "bootstrap_servers""}
What Broke
Users encounter a Kafka error when starting the worker due to incorrect configuration.
Fix Options (Details)
Option A — Apply the official fix
Fixes an invalid configuration key in the Kafka broker demo, changing 'bootstrap_servers' to 'bootstrap.servers'.
Fix reference: https://github.com/celery/celery/pull/10060
Last verified: 2026-02-08. Validate in your environment.
When NOT to Use This Fix
- Do not apply this fix if using a different Kafka client that supports 'bootstrap_servers'.
Did This Fix Work in Your Case?
Quick signal helps us prioritize which fixes to verify and improve.
Prevention
- Capture the exact failing error string in logs and tests so you can reproduce via a minimal script.
- Pin production dependencies and upgrade only with a reproducible test that hits the failing path.
Related Issues
No related fixes found.
Sources
We don’t republish the full GitHub discussion text. Use the links above for context.