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
{{ message }}
This repository was archived by the owner on Jun 10, 2022. It is now read-only.
| metadataRequestTimeoutMs | C/P | 10 .. 900000 | 60000 | Non-topic request timeout in milliseconds. This is for metadata requests, etc. |
11
-
| metadataRefreshIntervalMs | C/P | 10 .. 3600000 | 300000 | Topic metadata refresh interval in milliseconds. The metadata is automatically refreshed on error and connect. Use -1 to disable the intervalled refresh. |
9
+
| metadataBrokerList | C/P ||| Kafka Broker server list |
| metadataRefreshIntervalMs | C/P | 10 .. 3600000 | 300000 | Topic metadata refresh interval in milliseconds. The metadata is automatically refreshed on error and connect. Use -1 to disable the intervalled refresh. |
12
+
| metadataRequestTimeoutMs | C/P | 10 .. 900000 | 60000 | Non-topic request timeout in milliseconds. This is for metadata requests, etc. |
13
13
| sslEnable | C/P | true/false | false | Whether enable ssl connect or not |
14
+
| sslCafile | C/P ||| Location of Certificate Authority file on local filesystem which should be used with the verify_peer context option to authenticate the identity of the remote peer.|
14
15
| sslLocalCert | C/P | File path || Path to local certificate file on filesystem. |
15
16
| sslLocalPk | C/P | File path || Path to local private key file on filesystem in case of separate files for certificate (local_cert) and private key. |
| sslPassphrase | C/P ||| Passphrase with which your local_cert file was encoded. |
18
-
| sslCafile | C/P ||| Location of Certificate Authority file on local filesystem which should be used with the verify_peer context option to authenticate the identity of the remote peer.|
19
18
| sslPeerName | C/P ||| Peer name to be used. If this value is not set, then the name is guessed based on the hostname used when opening the stream. |
| offsetReset | C | latest,earliest | latest | Action to take when there is no initial offset in offset store or the desired offset is out of range |
25
-
| maxBytes | C || 65536 | Maximum bytes to fetch. |
26
-
| maxWaitTime | C || 100 | Maximum time in ms to wait for the response |
27
-
| requiredAck | P | -1 .. 1000 | 1 | This field indicates how many acknowledgements the leader broker must receive from ISR brokers before responding to the request: 0=Broker does not send any response/ack to client, 1=Only the leader broker will need to ack the message, -1 or all=broker will block until message is committed by all in sync replicas (ISRs) or broker\'s in.sync.replicas setting before sending response. |
| isAsyn | P | true, false | false | Whether to use asynchronous production messages |
30
-
| requestTimeout | P | 1 .. 900000 | 6000 | The total timeout of the production message, which must be greater than the timeout config parameter |
31
28
| produceInterval | P | 1 .. 900000 | 100 | The time interval at which requests for production messages are executed when the message is produced asynchronously |
29
+
| requestTimeout | P | 1 .. 900000 | 6000 | The total timeout of the production message, which must be greater than the timeout config parameter |
30
+
| requiredAck | P | -1 .. 1000 | 1 | This field indicates how many acknowledgements the leader broker must receive from ISR brokers before responding to the request: 0=Broker does not send any response/ack to client, 1=Only the leader broker will need to ack the message, -1 or all=broker will block until message is committed by all in sync replicas (ISRs) or broker\'s in.sync.replicas setting before sending response. |
0 commit comments