public final class PartitionInfoAdapter extends java.lang.Object implements Adapter<org.apache.kafka.common.PartitionInfo,PartitionInfo>
Constructor and Description |
---|
PartitionInfoAdapter() |
Modifier and Type | Method and Description |
---|---|
PartitionInfo |
adapt(org.apache.kafka.common.PartitionInfo sourcePartitionInfo)
Adapter pattern implementation for PartitionInfo instance.
|
public PartitionInfo adapt(org.apache.kafka.common.PartitionInfo sourcePartitionInfo)
org.apache.kafka.common.PartitionInfo
to a
com.opendxl.databus.common.PartitionInfo
instance.adapt
in interface Adapter<org.apache.kafka.common.PartitionInfo,PartitionInfo>
sourcePartitionInfo
- Instance of source org.apache.kafka.common.PartitionInfo.PartitionInfo
instance.