io.helidon.messaging.connectors.kafka.KafkaConfigBuilder
Description
Build Kafka specific config
Configuration options
| Key | Type | Description |
|---|---|---|
value- | Class | Deserializer class for value that implements the org. interface |
group- | String | A unique string that identifies the consumer group this consumer belongs to |
auto- | Auto | 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 |
topic- | Pattern | Pattern for topic names to consume from |
acks | String | The number of acknowledgments the producer requires the leader to have received before considering a request complete |
bootstrap- | String | A list of host/port pairs to use for establishing the initial connection to the Kafka cluster |
key- | Class | Serializer class for key that implements the org. interface |
enable- | Boolean | If true the consumer's offset will be periodically committed in the background |
batch- | Integer | The producer will attempt to batch records together into fewer requests whenever multiple records are being sent to the same partition |
dlq- | List< | Names of the "dead letter queue" topics to be used in case message is nacked |
retries | Integer | Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error |
buffer- | Long | The total bytes of memory the producer can use to buffer records waiting to be sent to the server |
poll- | Long | The maximum time to block polling loop in milliseconds |
compression- | String | The compression type for all data generated by the producer |
topic | List< | Names of the topics to consume from |
value- | Class | Serializer class for value that implements the org. interface |
period- | Long | Period between successive executions of polling loop |
key- | Class | Deserializer class for key that implements the org. interface |
See the manifest for all available types.