public interface IPartitionManager
Modifier and Type | Method and Description |
---|---|
void |
ack(String offset) |
void |
checkpoint() |
void |
close() |
void |
fail(String offset) |
Map<String,Object> |
getMetricsData() |
void |
open() |
EventDataWrap |
receive() |
Copyright © 2020 The Apache Software Foundation. All rights reserved.