Uses of Class
org.thales.punch.kafka.api.KafkaContinuousConsumerBuilder

Packages that use KafkaContinuousConsumerBuilder

Package	Description
org.thales.punch.kafka.api
org.thales.punch.kafka.platform

Uses of KafkaContinuousConsumerBuilder in org.thales.punch.kafka.api

Methods in org.thales.punch.kafka.api that return KafkaContinuousConsumerBuilder

Modifier and Type	Method and Description
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setAutoCommit() Start reading from the earliest offset.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setAutoCommitInterval(long interval) Set the auto commit interval
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setBootstrapServer(String bootstrapServers)
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setClientId(String consumerId)
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setEarliestStartOffsetStrategy() Start reading from the earliest offset.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setFromDatetimeStartOffsetStrategy(String datetime, String format)
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setFromDatetimeStartOffsetStrategy(String datetime, String format, boolean continueWhenNoRecords) Start reading from a specific datetime.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setFromOffsetStartStrategy(long offset) Start reading from an offset
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setGroupId(String groupId)
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setLastCommittedStartOffsetStrategy() Use a last commit strategy.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setLatestStartOffsetStrategy() Start reading from the latest offset.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setMetricContext(org.thales.punch.libraries.metrics.api.IMetricContext metricContext) Associate a metricContext to the kafka reader.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setOffsetTreeAckStrategy() Enable the ack and fail method of your IPartition handle to be handled using the underlyinh offset tree strategy.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setOffsetWatchDogTimeout(Long timeout) Set offset watchdog timeout.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setPartitionNumber(int num) Set a partition number if you want to consume only a given partition.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setProperties(Properties properties) Set additional properties, typically some defined in the kafka consumer javadocs.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setProperty(String name, Object value) Set additional property, typically some defined in the kafka consumer javadocs.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setSecurityStores(org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setSmartFailureHandling(boolean b) If set to true, after a failure already acked or pending records will not be reemitted.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setTickInterval(long i)
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setTopic(List<String> topics) Set the topics to be consumed by this consumer.
KafkaContinuousConsumerBuilder<K,V>	KafkaContinuousConsumerBuilder.setTopic(String... topic)

Uses of KafkaContinuousConsumerBuilder in org.thales.punch.kafka.platform

Methods in org.thales.punch.kafka.platform that return KafkaContinuousConsumerBuilder

Modifier and Type	Method and Description
static KafkaContinuousConsumerBuilder<String,byte[]>	KafkaShivaUtil.getContinuousConsumerBuilder(String bootstrapServers, String groupId, String... topics) This is a light helper to create continuous consumers well-configured for the punch internal kafka admin and shiva protocol.