confluent-kafka-python
confluent-kafka-python copied to clipboard
Docs Bug: `fetch.wait.max.ms` in consumer config but shows `fetch.max.wait.ms` in official docs
When I followed the consumer-config document and initial Consumer with additional config, following error occurred:
No such configuration property: "fetch.max.wait.ms"
[!NOTE] Rewrite to
fetch.wait.max.msand the error gone and the consumer successfully subscribe
Confluent Kafka Version
2.10.0
Reproduce
from confluent_kafka import Consumer
c = Consumer({
'bootstrap.servers': 'localhost:9093',
'group.id': 'confluent_kafka_test',
'auto.offset.reset': 'earliest',
'fetch.max.wait.ms': 1000,
})
c.subscribe(['test_topic'])
---------------------------------------------------------------------------
KafkaException Traceback (most recent call last)
1 from confluent_kafka import Consumer
----> 3 c = Consumer({
4 'bootstrap.servers': 'localhost:9093',
5 'group.id': 'confluent_kafka_test',
6 'auto.offset.reset': 'earliest',
7 'fetch.max.wait.ms': 1000,
8 })
10 c.subscribe(['test_topic'])
KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "fetch.max.wait.ms""}
Are you willing to submit a PR?
- [x] Yes I am willing to submit a PR!