ProcessId (streams 8.1.1-ce API)

java.lang.Object

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

All Implemented Interfaces:: Comparable<ProcessId>

public class ProcessIdextends 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>