Description
Build Kafka specific config.
Usages
Configuration options
| Key | Kind | Type | Description |
|---|---|---|---|
acks | VALUE | String | The number of acknowledgments the producer requires the leader to have received before considering a request complete |
auto-offset-reset | VALUE | i.h.m.c.k.K.AutoOffsetReset | What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g |
batch-size | VALUE | Integer | The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition |
bootstrap-servers | VALUE | String | A list of host/port pairs to use for establishing the initial connection to the Kafka cluster |
buffer-memory | VALUE | Long | The total bytes of memory the producer can use to buffer records waiting to be sent to the server |
compression-type | VALUE | String | The compression type for all data generated by the producer |
dlq-topic | LIST | String | Names of the "dead letter queue" topics to be used in case message is nacked |
enable-auto-commit | VALUE | Boolean | If true the consumer's offset will be periodically committed in the background |
group-id | VALUE | String | A unique string that identifies the consumer group this consumer belongs to |
key-deserializer | VALUE | Class | Deserializer class for key that implements the org.apache.kafka.common.serialization.Deserializer interface |
key-serializer | VALUE | Class | Serializer class for key that implements the org.apache.kafka.common.serialization.Serializer interface |
period-executions | VALUE | Long | Period between successive executions of polling loop |
poll-timeout | VALUE | Long | The maximum time to block polling loop in milliseconds |
retries | VALUE | Integer | Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error |
topic | LIST | String | Names of the topics to consume from |
topic-pattern | VALUE | Pattern | Pattern for topic names to consume from |
value-deserializer | VALUE | Class | Deserializer class for value that implements the org.apache.kafka.common.serialization.Deserializer interface |
value-serializer | VALUE | Class | Serializer class for value that implements the org.apache.kafka.common.serialization.Serializer interface |
See the manifest for all available types.