public class Helper extends Object
| Modifier and Type | Method and Description |
|---|---|
static Handler<Set<org.apache.kafka.common.TopicPartition>> |
adaptHandler(Handler<Set<TopicPartition>> handler) |
static Set<TopicPartition> |
from(Collection<org.apache.kafka.common.TopicPartition> topicPartitions) |
static Config |
from(org.apache.kafka.clients.admin.Config config) |
static ConfigEntry |
from(org.apache.kafka.clients.admin.ConfigEntry configEntry) |
static ConfigResource |
from(org.apache.kafka.common.config.ConfigResource configResource) |
static ConsumerGroupListing |
from(org.apache.kafka.clients.admin.ConsumerGroupListing consumerGroupListing) |
static Map<TopicPartition,OffsetAndMetadata> |
from(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets) |
static MemberAssignment |
from(org.apache.kafka.clients.admin.MemberAssignment memberAssignment) |
static Node |
from(org.apache.kafka.common.Node node) |
static OffsetAndMetadata |
from(org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata) |
static RecordMetadata |
from(org.apache.kafka.clients.producer.RecordMetadata metadata) |
static TopicPartition |
from(org.apache.kafka.common.TopicPartition topicPartition) |
static List<ConfigEntry> |
fromConfigEntries(Collection<org.apache.kafka.clients.admin.ConfigEntry> configEntries) |
static List<ConsumerGroupListing> |
fromConsumerGroupListings(Collection<org.apache.kafka.clients.admin.ConsumerGroupListing> consumerGroupListings) |
static Map<TopicPartition,OffsetAndTimestamp> |
fromTopicPartitionOffsetAndTimestamp(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndTimestamp> topicPartitionOffsetAndTimestamps) |
static Map<TopicPartition,Long> |
fromTopicPartitionOffsets(Map<org.apache.kafka.common.TopicPartition,Long> offsets) |
static org.apache.kafka.clients.admin.ConfigEntry |
to(ConfigEntry configEntry) |
static org.apache.kafka.common.config.ConfigResource |
to(ConfigResource configResource) |
static Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> |
to(Map<TopicPartition,OffsetAndMetadata> offsets) |
static org.apache.kafka.clients.admin.NewTopic |
to(NewTopic topic) |
static org.apache.kafka.clients.consumer.OffsetAndMetadata |
to(OffsetAndMetadata offsetAndMetadata) |
static Set<org.apache.kafka.common.TopicPartition> |
to(Set<TopicPartition> topicPartitions) |
static org.apache.kafka.common.TopicPartition |
to(TopicPartition topicPartition) |
static Collection<org.apache.kafka.clients.admin.ConfigEntry> |
toConfigEntryList(List<ConfigEntry> configEntries) |
static Map<org.apache.kafka.common.config.ConfigResource,org.apache.kafka.clients.admin.Config> |
toConfigMaps(Map<ConfigResource,Config> configs) |
static List<org.apache.kafka.common.config.ConfigResource> |
toConfigResourceList(List<ConfigResource> configResources) |
static List<org.apache.kafka.clients.admin.NewTopic> |
toNewTopicList(List<NewTopic> topics) |
static <T> Set<T> |
toSet(Collection<T> collection) |
static Map<org.apache.kafka.common.TopicPartition,Long> |
toTopicPartitionTimes(Map<TopicPartition,Long> topicPartitionTimes) |
public static <T> Set<T> toSet(Collection<T> collection)
public static org.apache.kafka.common.TopicPartition to(TopicPartition topicPartition)
public static Set<org.apache.kafka.common.TopicPartition> to(Set<TopicPartition> topicPartitions)
public static Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> to(Map<TopicPartition,OffsetAndMetadata> offsets)
public static Map<TopicPartition,OffsetAndMetadata> from(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
public static TopicPartition from(org.apache.kafka.common.TopicPartition topicPartition)
public static Set<TopicPartition> from(Collection<org.apache.kafka.common.TopicPartition> topicPartitions)
public static Handler<Set<org.apache.kafka.common.TopicPartition>> adaptHandler(Handler<Set<TopicPartition>> handler)
public static Node from(org.apache.kafka.common.Node node)
public static RecordMetadata from(org.apache.kafka.clients.producer.RecordMetadata metadata)
public static OffsetAndMetadata from(org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata)
public static org.apache.kafka.clients.consumer.OffsetAndMetadata to(OffsetAndMetadata offsetAndMetadata)
public static Map<TopicPartition,Long> fromTopicPartitionOffsets(Map<org.apache.kafka.common.TopicPartition,Long> offsets)
public static Map<org.apache.kafka.common.TopicPartition,Long> toTopicPartitionTimes(Map<TopicPartition,Long> topicPartitionTimes)
public static Map<TopicPartition,OffsetAndTimestamp> fromTopicPartitionOffsetAndTimestamp(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndTimestamp> topicPartitionOffsetAndTimestamps)
public static org.apache.kafka.clients.admin.NewTopic to(NewTopic topic)
public static org.apache.kafka.common.config.ConfigResource to(ConfigResource configResource)
public static ConfigResource from(org.apache.kafka.common.config.ConfigResource configResource)
public static Config from(org.apache.kafka.clients.admin.Config config)
public static List<org.apache.kafka.clients.admin.NewTopic> toNewTopicList(List<NewTopic> topics)
public static List<org.apache.kafka.common.config.ConfigResource> toConfigResourceList(List<ConfigResource> configResources)
public static Collection<org.apache.kafka.clients.admin.ConfigEntry> toConfigEntryList(List<ConfigEntry> configEntries)
public static org.apache.kafka.clients.admin.ConfigEntry to(ConfigEntry configEntry)
public static Map<org.apache.kafka.common.config.ConfigResource,org.apache.kafka.clients.admin.Config> toConfigMaps(Map<ConfigResource,Config> configs)
public static ConfigEntry from(org.apache.kafka.clients.admin.ConfigEntry configEntry)
public static List<ConfigEntry> fromConfigEntries(Collection<org.apache.kafka.clients.admin.ConfigEntry> configEntries)
public static ConsumerGroupListing from(org.apache.kafka.clients.admin.ConsumerGroupListing consumerGroupListing)
public static List<ConsumerGroupListing> fromConsumerGroupListings(Collection<org.apache.kafka.clients.admin.ConsumerGroupListing> consumerGroupListings)
public static MemberAssignment from(org.apache.kafka.clients.admin.MemberAssignment memberAssignment)
Copyright © 2020. All rights reserved.