- java.lang.Object
-
- org.apache.kafka.connect.storage.MemoryOffsetBackingStore
-
- org.springframework.cloud.fn.common.cdc.store.MetadataStoreOffsetBackingStore
-
-
Field Summary
-
Fields inherited from class org.apache.kafka.connect.storage.MemoryOffsetBackingStore
data, executor
-
Method Summary
-
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
-
-
Method Detail
-
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
Copyright © 2020. All rights reserved.