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

Class GroupMetadataUpdateEvent

java.lang.Object

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

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

public class GroupMetadataUpdateEvent
extends BackgroundEvent

This event is sent by the consumer's network thread to the application thread so that when the user calls the Consumer.groupMetadata() API, the information is up-to-date. The information for the current state of the group member is managed on the consumer network thread and thus requires this interplay between threads.

Nested Class Summary

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

BackgroundEvent.Type

Constructor Summary

Constructors

Constructor	Description
GroupMetadataUpdateEvent(int memberEpoch, String memberId)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
int	memberEpoch()
String	memberId()
String	toString()
String	toStringBase()

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

type

Methods inherited from class java.lang.Object

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

Constructor Details

GroupMetadataUpdateEvent

public GroupMetadataUpdateEvent(int memberEpoch,
 String memberId)

Method Details

memberEpoch

public int memberEpoch()

memberId

public String memberId()

equals

public boolean equals(Object o)

Overrides:

equals in class BackgroundEvent

hashCode

public int hashCode()

Overrides:

hashCode in class BackgroundEvent

toStringBase

public String toStringBase()

Overrides:

toStringBase in class BackgroundEvent

toString

public String toString()

Overrides:

toString in class BackgroundEvent