-
Notifications
You must be signed in to change notification settings - Fork 920
Open
Labels
status:needs-more-infoIssues that require more information to cleanup.Issues that require more information to cleanup.
Description
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.ms
and 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.wait.max.ms': 1000,
})
c.subscribe(['test_topic'])
---------------------------------------------------------------------------
KafkaException Traceback (most recent call last)
Cell In[4], line 3
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.wait.max.ams': 1000,
8 })
10 c.subscribe(['test_topic'])
KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "fetch.wait.max.ams""}
Are you willing to submit a PR?
- Yes I am willing to submit a PR!
Metadata
Metadata
Assignees
Labels
status:needs-more-infoIssues that require more information to cleanup.Issues that require more information to cleanup.