Interface Committer

All Superinterfaces:
Runnable

public interface Committer extends Runnable
Committer includes a Runnable and a Jackson-serialized metadata object containing the offset
  • Method Summary

    Modifier and Type
    Method
    Description
     

    Methods inherited from interface java.lang.Runnable

    run
  • Method Details

    • getMetadata

      @Nullable Object getMetadata()
      Returns:
      A json serialized representation of commit metadata, which needs to be serialized and deserialized by Jackson. Commit metadata can be a complex type, but we recommend keeping it to List/Map/"Primitive JSON" types