| Package | Description |
|---|---|
| com.github.jcustenborder.kafka.connect.utils.data |
| Modifier and Type | Method and Description |
|---|---|
static SinkOffsetState |
SinkOffsetState.of(String topic,
int partition,
long offset) |
static SinkOffsetState |
SinkOffsetState.of(org.apache.kafka.common.TopicPartition topicPartition,
long offset) |
| Modifier and Type | Method and Description |
|---|---|
int |
SinkOffsetState.compareTo(SinkOffsetState that) |
Copyright © 2016–2025. All rights reserved.