Package org.apache.kafka.streams.processor.assignment

Class KafkaStreamsAssignment.AssignedTask

java.lang.Object

org.apache.kafka.streams.processor.assignment.KafkaStreamsAssignment.AssignedTask

Enclosing class:

KafkaStreamsAssignment

public static class KafkaStreamsAssignment.AssignedTask
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	KafkaStreamsAssignment.AssignedTask.Type

Constructor Summary

Constructors

Constructor	Description
AssignedTask(TaskId id, KafkaStreamsAssignment.AssignedTask.Type taskType)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
int	hashCode()
TaskId	id()
String	toString()
KafkaStreamsAssignment.AssignedTask.Type	type()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

AssignedTask

public AssignedTask(TaskId id,
 KafkaStreamsAssignment.AssignedTask.Type taskType)

Method Details

id

public TaskId id()

Returns:

the id of the AssignedTask

type

public KafkaStreamsAssignment.AssignedTask.Type type()

Returns:

the type of the AssignedTask

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object