Package com.bakdata.kafka.admin

Class TopicsClient

java.lang.Object

com.bakdata.kafka.admin.TopicsClient

public final class TopicsClient
extends Object

This class offers helpers to interact with Kafka topics.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	TopicsClient.TopicClient	A client for a specific topic.

Method Summary

Modifier and Type	Method	Description
Collection<String>	list()	List Kafka topics.
Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo>	listOffsets(Iterable<org.apache.kafka.common.TopicPartition> topicPartitions)	List offsets for a set of partitions.
TopicsClient.TopicClient	topic(String topicName)	Create a client for a specific topic.

Methods inherited from class java.lang.Object

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

Method Details

listOffsets

public Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo> listOffsets(Iterable<org.apache.kafka.common.TopicPartition> topicPartitions)

List offsets for a set of partitions.

Parameters:

topicPartitions - partitions to list offsets for

Returns:

partition offsets

list

public Collection<String> list()

List Kafka topics.

Returns:

name of all existing Kafka topics

topic

public TopicsClient.TopicClient topic(String topicName)

Create a client for a specific topic.

Parameters:

topicName - topic name

Returns:

a topic client for the specified topic