5.8.1 Kafka Configuration Fields
Table 5-7 Kafka fields
Field | Description | Data Input Notes |
---|---|---|
Remote Server Name* | Unique identifier used to label a Remote Server. | Format: Text box
Default: NA Range: A 32 character string. Valid characters are alphanumeric, minus sign, period, and underscore. Must start with an alphanumeric or an underscore and end with an alphanumeric. A value is required. |
Broker IPs* | IP and port of Kafka cluster. | Format: Text box
Default: NA Range: Any valid IPv4 address with port. A value is required. |
Topic Name * | Defines Kafka's topic name which is a fundamental unit
for event or message organization. Messages with the same topic name
will be appended one after another creating a Log file. Producers can
push messages into the tail of these logs while consumers pull messages
off from the head. It is possible to get logical segregation between
messages and events, similar to how various tables in a database can
contain different sorts of data.
Note: Topic name is default and cannot be modified. |
Format: Text box
Default: com.oracle.dsr.idih.ttr Range: Topic name can include the following characters: a-z, A-Z, 0-9, . (dot), _ (underscore), and - (dash)] [A value is required.] |
Compression Codec | To be used for compressing message sets. | Format: Drop-down
Default: Gzip Range: None, Gzip, Snappy, Lz4 |
Compression Level | Compression level parameter for algorithm selected by configuration property compression.codec. Higher values will result in better compression at the cost of more CPU usage. | Format: Text box
Default: 0 Range: [0-9] for gzip, [0-12] for lz4, only 0 for snappy.] |
Batch Size | The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition. | Format: Text box
Default: 16384 Range: 0-16384 |
Max Request Size | The maximum size of a request in bytes. This setting will limit the number of record batches the producer will send in a single request to avoid sending huge requests. | Format: Text box
Default: 1048576 Range: 0-1048576 |
Linger Time | Delay in milliseconds to wait for messages in the producer queue to accumulate before constructing message batches (MessageSets) to transmit to brokers. | Format: Text box
Default: 0 Range: 0 |
Acknowledgements | Number of replicas to be written successfully before acknowledging the publish request. | Format: Text box
Default: 1 Range: -1 or all, 0, 1 |
Max Idle Time | Closes idle connections after the number of milliseconds specified by this configuration. | Format: Text box
Default: 540000 Range: 0-3600000 |
Socket Connection Timeout | The amount of time the client will wait for the socket connection to be established. If the connection is not built before the timeout elapses, clients will close the socket channel. | Format: Text box
Default: 10000 Range: 0-10000 |
Send Buffer Size | The size of the TCP send buffer (SO_SNDBUF) to use when sending data. If the value is -1, the OS default will be used. | Format: Text box
Default: 131072 Range: 0-131072 |
Max In Flight Request | The maximum number of unacknowledged requests the client will send on a single connection before blocking. | Format: Text box
Default: 5 Range: 0 - 5 |
Max Request Timeout | This controls the maximum amount of time (in milliseconds) the client will wait for the response of a request. If the response is not received before the timeout elapses, the client will resend the request if necessary or fail the request if retries are exhausted. | Format: Text box
Default: 30000 Range: 0-30000 |
Max Retries | Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error. | Format: Text box
Default: 2147483647 Range: 0-2147483647 |
Max Delivery Timeout | An upper bound on how long it takes to communicate success or failure after calling send() returns. This limits the total time that a record will be delayed prior to sending the report, the time to await acknowledgement from the broker (if expected), and the time allowed for retriable send failure. | Format: Text box
Default: 120000 Range: 0-120000 |
Metadata Max Age | The period of time in milliseconds after which we force a refresh of metadata even if we haven’t seen any partition leadership changes to proactively discover any new brokers or partitions. | Format: Text box
Default: 300000 Range: 0-300000 |
Reconnect Backoff Max Time | The maximum amount of time in milliseconds to wait when reconnecting to a broker that has repeatedly failed to connect. If provided, the backoff per host will increase exponentially for each consecutive connection failure, up to this maximum time. After calculating the backoff increase, 20% random jitter is added to avoid connection storms. | Format: Text box
Default: 1000 Range: 0-1000 |
Reconnect Backoff Time | The base amount of time to wait before attempting to reconnect to a given host. This avoids repeatedly connecting to a host in a tight loop. This backoff applies to all connection attempts by the client to a broker. | Format: Text box
Default: 50 Range: 0-50 |
Retry Backoff Time | The amount of time to wait before attempting to retry a failed request to a given topic partition. This avoids repeatedly sending requests in a tight loop under some failure scenarios. | Format: Text box
Default: 100 Range: 0-100 |
Max Connection Retry | Time in minutes within which the producer instance makes maximum number of retries to fetch the metadata from the kafka server. | Format: Text box
Default: 10 Range: 2-10 minutes |
Security Protocol | Protocol used to communicate with brokers. | Format: Text box
Default: SSL Range: PLAINTEXT, SSL |
Table 5-8 SSL Properties
Field | Description | Data Input Notes |
---|---|---|
SSL Certificate | File name of file in PEM format containing the client certificate. | Format: Browse to select the file. |
SSL Key | File name of file in PEM format containing the client private key in encrypted format. | Format: Browse to select the file. |
SSL CA | File name of CA in PEM format to be used for certificate verification | Format: Browse to select the file. |
SASL Username | Enter the SASL (Simple Authentication and Security Layer) user name that will be used for authenticating your Kafka client. | Format: Text box
Default: NA Range: The length of the user name should be between 8 and 64 characters. The user name accepts only alphanumeric characters. |
SASL Password | Enter the SASL (Simple Authentication and Security Layer) password that will be used for authenticating your Kafka client. | Format: Text box
Default: NA Range: The length of the user name should be between 8 and 64 characters. The user name accepts only alphanumeric characters |