Package org.apache.kafka.clients.consumer.internals.events

Class TopicMetadataApplicationEvent

java.lang.Object

org.apache.kafka.clients.consumer.internals.events.ApplicationEvent

org.apache.kafka.clients.consumer.internals.events.CompletableApplicationEvent<Map<String,List<org.apache.kafka.common.PartitionInfo>>>

org.apache.kafka.clients.consumer.internals.events.TopicMetadataApplicationEvent

All Implemented Interfaces:

CompletableEvent<Map<String,List<org.apache.kafka.common.PartitionInfo>>>

public class TopicMetadataApplicationEvent
extends CompletableApplicationEvent<Map<String,List<org.apache.kafka.common.PartitionInfo>>>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.clients.consumer.internals.events.ApplicationEvent

ApplicationEvent.Type

Constructor Summary

Constructors

Constructor	Description
TopicMetadataApplicationEvent(long timeoutMs)
TopicMetadataApplicationEvent(String topic, long timeoutMs)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
long	getTimeoutMs()
int	hashCode()
boolean	isAllTopics()
String	topic()
String	toString()

Methods inherited from class org.apache.kafka.clients.consumer.internals.events.CompletableApplicationEvent

chain, future, get, toStringBase

Methods inherited from class org.apache.kafka.clients.consumer.internals.events.ApplicationEvent

type

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

TopicMetadataApplicationEvent

public TopicMetadataApplicationEvent(long timeoutMs)

TopicMetadataApplicationEvent

public TopicMetadataApplicationEvent(String topic,
 long timeoutMs)

Method Details

topic

public String topic()

isAllTopics

public boolean isAllTopics()

getTimeoutMs

public long getTimeoutMs()

toString

public String toString()

Overrides:

toString in class CompletableApplicationEvent<Map<String,List<org.apache.kafka.common.PartitionInfo>>>

equals

public boolean equals(Object o)

Overrides:

equals in class CompletableApplicationEvent<Map<String,List<org.apache.kafka.common.PartitionInfo>>>

hashCode

public int hashCode()

Overrides:

hashCode in class CompletableApplicationEvent<Map<String,List<org.apache.kafka.common.PartitionInfo>>>