org.springframework.integration.x.kafka

Interface DeletableOffsetManager

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, java.io.Flushable, org.springframework.integration.kafka.listener.OffsetManager

All Known Implementing Classes:

SpringXdOffsetManager

public interface DeletableOffsetManager
extends org.springframework.integration.kafka.listener.OffsetManager

An OffsetManager with the ability of deleting entries To be refactored once https://jira.spring.io/browse/INTEXT-131 is fixed

Author:

Marius Bogoevici

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteOffset(org.springframework.integration.kafka.core.Partition partition) Removes the offset for a given Partition.

Methods inherited from interface org.springframework.integration.kafka.listener.OffsetManager

getOffset, resetOffsets, updateOffset

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface java.io.Flushable

flush

Method Detail

deleteOffset

void deleteOffset(org.springframework.integration.kafka.core.Partition partition)

Removes the offset for a given Partition.

Parameters:

partition -