org.thales.punch.kafka.api

Class KafkaSettingsMapConsumerBuilder

java.lang.Object

org.thales.punch.kafka.api.KafkaSettingsMapConsumerBuilder

public class KafkaSettingsMapConsumerBuilder
extends Object

The IKafkaContinuousConsumer builder. Refer the the kafka KafkaConsumer javadoc. Here is an example :

 kafkaReader = new KafkaConsumerBuilder("localhost:9092", "admin-topic")
      .setGroupId("mytenant_apache_processing")
      .setTopic("apache")
      .setStartOffsetStrategy("earliest")
      .setMetricContext(yourMetricContext)
      .build();
 

It is handy to pass in additional kafka standard properties. You can do that using the For example :

 kafkaReader = new KafkaReaderBuilder<byte[], byte[]>()
      .setProperty("fetch.max.bytes", 1048576)
      ...
      .build();
 

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
KafkaSettingsMapConsumerBuilder()

Method Summary

Modifier and Type	Method and Description
KafkaAdminConsumer	build()
KafkaSettingsMapConsumerBuilder	setBootstrapServer(String bootstrapServers)
KafkaSettingsMapConsumerBuilder	setClientId(String clientId)
KafkaSettingsMapConsumerBuilder	setGroupId(String groupId)
KafkaSettingsMapConsumerBuilder	setSecurityStores(org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)
KafkaSettingsMapConsumerBuilder	setTopic(String topic)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaSettingsMapConsumerBuilder

public KafkaSettingsMapConsumerBuilder()

Method Detail

setBootstrapServer

public KafkaSettingsMapConsumerBuilder setBootstrapServer(String bootstrapServers)

Parameters:

bootstrapServers - the bootstrap server(s) address

Returns:

this builder

setGroupId

public KafkaSettingsMapConsumerBuilder setGroupId(String groupId)

Parameters:

groupId -

Returns:

this builder

setClientId

public KafkaSettingsMapConsumerBuilder setClientId(String clientId)

setSecurityStores

public KafkaSettingsMapConsumerBuilder setSecurityStores(org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)

setTopic

public KafkaSettingsMapConsumerBuilder setTopic(String topic)

Parameters:

topic -

Returns:

this builder

build

public KafkaAdminConsumer build()