com.opendxl.databus.common.internal.adapter

Class TopicPartitionAdapter

java.lang.Object

com.opendxl.databus.common.internal.adapter.TopicPartitionAdapter

All Implemented Interfaces:

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

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

Adapter for TopicPartition

Constructor Summary

Constructors

Constructor and Description
TopicPartitionAdapter()

Method Summary

Modifier and Type	Method and Description
TopicPartition	adapt(org.apache.kafka.common.TopicPartition sourceTopicPartition) Gets a TopicPartition instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicPartitionAdapter

public TopicPartitionAdapter()

Method Detail

adapt

public TopicPartition adapt(org.apache.kafka.common.TopicPartition sourceTopicPartition)

Gets a TopicPartition instance.

Specified by:

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

Parameters:

sourceTopicPartition - source topic partition.

Returns:

TopicPartition instance.