Interface OffsetAndMetadataProvider


public interface OffsetAndMetadataProvider
Provider for OffsetAndMetadata. The provider can be used to have more granularity when creating an OffsetAndMetadata. The provider is used for both sync and async commits of the offsets.
Since:
2.8.5
Author:
Francois Rosiere
See Also:
  • OffsetCommitCallback
  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.clients.consumer.OffsetAndMetadata
    provide(ListenerMetadata listenerMetadata, long offset)
    Provide an offset and metadata object for the given listener metadata and offset.
  • Method Details

    • provide

      org.apache.kafka.clients.consumer.OffsetAndMetadata provide(ListenerMetadata listenerMetadata, long offset)
      Provide an offset and metadata object for the given listener metadata and offset.
      Parameters:
      listenerMetadata - metadata associated to a listener.
      offset - an offset.
      Returns:
      an offset and metadata.