KafkaConfigBuilder |
KafkaConfigBuilder.acks(String acks) |
The number of acknowledgments the producer requires the leader to have received before considering a request complete.
|
KafkaConfigBuilder |
KafkaConfigBuilder.autoOffsetReset(KafkaConfigBuilder.AutoOffsetReset 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.
|
KafkaConfigBuilder |
KafkaConfigBuilder.batchSize(int batchSize) |
The producer will attempt to batch records together into fewer requests whenever multiple records
are being sent to the same partition.
|
KafkaConfigBuilder |
KafkaConfigBuilder.bootstrapServers(String servers) |
A list of host/port pairs to use for establishing the initial connection to the Kafka cluster.
|
KafkaConfigBuilder |
KafkaConfigBuilder.bufferMemory(long bufferMemory) |
The total bytes of memory the producer can use to buffer records waiting to be sent to the server.
|
KafkaConfigBuilder |
KafkaConfigBuilder.compressionType(String compressionType) |
The compression type for all data generated by the producer.
|
static KafkaConfigBuilder |
KafkaConnector.configBuilder() |
Custom config builder for Kafka connector.
|
KafkaConfigBuilder |
KafkaConfigBuilder.enableAutoCommit(boolean enableAutoCommit) |
If true the consumer's offset will be periodically committed in the background.
|
KafkaConfigBuilder |
KafkaConfigBuilder.groupId(String groupId) |
A unique string that identifies the consumer group this consumer belongs to.
|
KafkaConfigBuilder |
KafkaConfigBuilder.keyDeserializer(Class<? extends org.apache.kafka.common.serialization.Deserializer<?>> keyDeserializer) |
Deserializer class for key that implements the Deserializer interface.
|
KafkaConfigBuilder |
KafkaConfigBuilder.keySerializer(Class<? extends org.apache.kafka.common.serialization.Serializer<?>> keySerializer) |
Serializer class for key that implements the Serializer interface.
|
KafkaConfigBuilder |
KafkaConfigBuilder.periodExecutions(long periodExecutions) |
Period between successive executions of polling loop.
|
KafkaConfigBuilder |
KafkaConfigBuilder.pollTimeout(long pollTimeout) |
The maximum time to block polling loop in milliseconds.
|
KafkaConfigBuilder |
KafkaConfigBuilder.property(String key,
String value) |
Add custom property.
|
KafkaConfigBuilder |
KafkaConfigBuilder.retries(int retries) |
Setting a value greater than zero will cause the client to resend any record whose send
fails with a potentially transient error.
|
KafkaConfigBuilder |
KafkaConfigBuilder.topic(String... topics) |
Names of the topics to consume from.
|
KafkaConfigBuilder |
KafkaConfigBuilder.topicPattern(String topicPattern) |
Regex pattern for topic names to consume from.
|
KafkaConfigBuilder |
KafkaConfigBuilder.topicPattern(Pattern topicPattern) |
Pattern for topic names to consume from.
|
KafkaConfigBuilder |
KafkaConfigBuilder.valueDeserializer(Class<? extends org.apache.kafka.common.serialization.Deserializer<?>> valueDeserializer) |
Deserializer class for value that implements the Deserializer interface.
|
KafkaConfigBuilder |
KafkaConfigBuilder.valueSerializer(Class<? extends org.apache.kafka.common.serialization.Serializer<?>> valueSerializer) |
Serializer class for value that implements the Serializer interface.
|