com.opendxl.databus.common.internal.adapter

Class PartitionInfoAdapter

java.lang.Object

com.opendxl.databus.common.internal.adapter.PartitionInfoAdapter

All Implemented Interfaces:

Adapter<org.apache.kafka.common.PartitionInfo,PartitionInfo>

public final class PartitionInfoAdapter
extends java.lang.Object
implements Adapter<org.apache.kafka.common.PartitionInfo,PartitionInfo>

Adapter for PartitionInfo.

Constructor Summary

Constructors

Constructor and Description
PartitionInfoAdapter()

Method Summary

Modifier and Type	Method and Description
PartitionInfo	adapt(org.apache.kafka.common.PartitionInfo sourcePartitionInfo) Adapter pattern implementation for PartitionInfo instance.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionInfoAdapter

public PartitionInfoAdapter()

Method Detail

adapt

public PartitionInfo adapt(org.apache.kafka.common.PartitionInfo sourcePartitionInfo)

Adapter pattern implementation for PartitionInfo instance. Adapts a org.apache.kafka.common.PartitionInfo to a com.opendxl.databus.common.PartitionInfo instance.

Specified by:

adapt in interface Adapter<org.apache.kafka.common.PartitionInfo,PartitionInfo>

Parameters:

sourcePartitionInfo - Instance of source org.apache.kafka.common.PartitionInfo.

Returns:

A PartitionInfo instance.