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

Class ProcessId

java.lang.Object

org.apache.kafka.streams.processor.assignment.ProcessId

All Implemented Interfaces:

Comparable<ProcessId>

public class ProcessId
extends Object
implements Comparable<ProcessId>

A simple wrapper around UUID that abstracts a Process ID

Constructor Summary

Constructors

Constructor	Description
ProcessId(UUID id)

Method Summary

Modifier and Type	Method	Description
int	compareTo(ProcessId o)
boolean	equals(Object obj)
int	hashCode()
UUID	id()
static ProcessId	randomProcessId()
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ProcessId

public ProcessId(UUID id)

Method Details

id

public UUID id()

Returns:

the underlying UUID that this ProcessID is wrapping.

randomProcessId

public static ProcessId randomProcessId()

Returns:

a randomly generated process id

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

compareTo

public int compareTo(ProcessId o)

Specified by:

compareTo in interface Comparable<ProcessId>