public interface IPartitionManager
Modifier and Type | Method and Description |
---|---|
void |
ack(String offset) |
void |
checkpoint() |
void |
close() |
void |
fail(String offset) |
Map |
getMetricsData() |
void |
open() |
EventData |
receive() |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.