File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -120,9 +120,9 @@ class KafkaConsumer(six.Iterator):
120
120
receive_buffer_bytes (int): The size of the TCP receive buffer
121
121
(SO_RCVBUF) to use when reading data. Default: None (relies on
122
122
system defaults). The java client defaults to 32768.
123
- consumer_timeout_ms (int): number of millisecond to throw a timeout
124
- exception to the consumer if no message is available for
125
- consumption . Default: -1 (dont throw exception)
123
+ consumer_timeout_ms (int): number of milliseconds to block during
124
+ message iteration before raising StopIteration (i.e., ending the
125
+ iterator) . Default -1 (block forever).
126
126
security_protocol (str): Protocol used to communicate with brokers.
127
127
Valid values are: PLAINTEXT, SSL. Default: PLAINTEXT.
128
128
ssl_context (ssl.SSLContext): pre-configured SSLContext for wrapping
You can’t perform that action at this time.
0 commit comments