org.springframework.integration.x.kafka

Class KafkaTopicMetadataStore

java.lang.Object

org.springframework.integration.x.kafka.KafkaTopicMetadataStore

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.springframework.beans.factory.InitializingBean, org.springframework.integration.metadata.MetadataStore

public class KafkaTopicMetadataStore
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.integration.metadata.MetadataStore, java.io.Closeable

Implementation of a MetadataStore that uses a Kafka topic as the underlying support. For its proper functioning, the Kafka server(s) must set log.cleaner.enable=true.

Author:

Marius Bogoevici

Field Summary

Fields

Modifier and Type	Field and Description
static org.springframework.integration.kafka.serializer.common.StringDecoder	DECODER
static org.springframework.integration.kafka.serializer.common.StringEncoder	ENCODER

Constructor Summary

Constructors

Constructor and Description
KafkaTopicMetadataStore(org.springframework.integration.kafka.support.ZookeeperConnect zookeeperConnect, org.springframework.integration.kafka.core.ConnectionFactory connectionFactory, java.lang.String topic)

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	close()
java.lang.String	get(java.lang.String key)
void	put(java.lang.String key, java.lang.String value)
java.lang.String	remove(java.lang.String key)
void	setCompressionCodec(java.lang.String compressionCodec) The compression codec for writing to the offset topic
void	setMaxBatchSize(int maxBatchSize) The maximum batch size for offset writes
void	setMaxQueueBufferingTime(int maxQueueBufferingTime) For how long will producers buffer data before writing to the topic
void	setMaxSize(int maxSize) Sets the maximum size of a fetch request, allowing to tune the initialization process.
void	setReplicationFactor(int replicationFactor) The replication factor of the offset topic
void	setRetentionTime(int retentionTime) How long are dead records retained in the offset topic
void	setSegmentSize(int segmentSize) The size of a segment in the offset topic

Methods inherited from class java.lang.Object

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

Field Detail

ENCODER

public static final org.springframework.integration.kafka.serializer.common.StringEncoder ENCODER

DECODER

public static final org.springframework.integration.kafka.serializer.common.StringDecoder DECODER

Constructor Detail

KafkaTopicMetadataStore

public KafkaTopicMetadataStore(org.springframework.integration.kafka.support.ZookeeperConnect zookeeperConnect,
                       org.springframework.integration.kafka.core.ConnectionFactory connectionFactory,
                       java.lang.String topic)

Method Detail

setMaxSize

public void setMaxSize(int maxSize)

Sets the maximum size of a fetch request, allowing to tune the initialization process.

Parameters:

maxSize - the maximum amount of data to be brought on a fetch

setCompressionCodec

public void setCompressionCodec(java.lang.String compressionCodec)

The compression codec for writing to the offset topic

Parameters:

compressionCodec - the compression codec

setMaxQueueBufferingTime

public void setMaxQueueBufferingTime(int maxQueueBufferingTime)

For how long will producers buffer data before writing to the topic

Parameters:

maxQueueBufferingTime -

setSegmentSize

public void setSegmentSize(int segmentSize)

The size of a segment in the offset topic

Parameters:

segmentSize -

setRetentionTime

public void setRetentionTime(int retentionTime)

How long are dead records retained in the offset topic

Parameters:

retentionTime -

setReplicationFactor

public void setReplicationFactor(int replicationFactor)

The replication factor of the offset topic

Parameters:

replicationFactor -

setMaxBatchSize

public void setMaxBatchSize(int maxBatchSize)

The maximum batch size for offset writes

Parameters:

maxBatchSize -

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

put

public void put(java.lang.String key,
       java.lang.String value)

Specified by:

put in interface org.springframework.integration.metadata.MetadataStore

get

public java.lang.String get(java.lang.String key)

Specified by:

get in interface org.springframework.integration.metadata.MetadataStore

remove

public java.lang.String remove(java.lang.String key)

Specified by:

remove in interface org.springframework.integration.metadata.MetadataStore

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException