org.springframework.cloud.fn.common.cdc.store

Class MetadataStoreOffsetBackingStore

java.lang.Object

org.apache.kafka.connect.storage.MemoryOffsetBackingStore

org.springframework.cloud.fn.common.cdc.store.MetadataStoreOffsetBackingStore

All Implemented Interfaces:

org.apache.kafka.connect.storage.OffsetBackingStore

public class MetadataStoreOffsetBackingStore
extends org.apache.kafka.connect.storage.MemoryOffsetBackingStore

Author:

Christian Tzolov

Field Summary

Fields inherited from class org.apache.kafka.connect.storage.MemoryOffsetBackingStore

data, executor

Constructor Summary

Constructors

Constructor and Description
MetadataStoreOffsetBackingStore(org.springframework.integration.metadata.MetadataStore metadataStore)

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.kafka.connect.runtime.WorkerConfig config)
protected void	save()
void	start()
void	stop()

Methods inherited from class org.apache.kafka.connect.storage.MemoryOffsetBackingStore

get, set

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataStoreOffsetBackingStore

public MetadataStoreOffsetBackingStore(org.springframework.integration.metadata.MetadataStore metadataStore)

Method Detail

configure

public void configure(org.apache.kafka.connect.runtime.WorkerConfig config)

Specified by:

configure in interface org.apache.kafka.connect.storage.OffsetBackingStore

Overrides:

configure in class org.apache.kafka.connect.storage.MemoryOffsetBackingStore

start

public void start()

Specified by:

start in interface org.apache.kafka.connect.storage.OffsetBackingStore

Overrides:

start in class org.apache.kafka.connect.storage.MemoryOffsetBackingStore

stop

public void stop()

Specified by:

stop in interface org.apache.kafka.connect.storage.OffsetBackingStore

Overrides:

stop in class org.apache.kafka.connect.storage.MemoryOffsetBackingStore

save

protected void save()

Overrides:

save in class org.apache.kafka.connect.storage.MemoryOffsetBackingStore