public class KafkaCruiseControlThreadFactory
extends java.lang.Object
implements java.util.concurrent.ThreadFactory
Constructor and Description |
---|
KafkaCruiseControlThreadFactory(java.lang.String name,
boolean daemon,
org.slf4j.Logger logger) |
KafkaCruiseControlThreadFactory(java.lang.String name,
boolean daemon,
org.slf4j.Logger logger,
java.util.Optional<java.lang.Integer> brokerId) |
Modifier and Type | Method and Description |
---|---|
java.lang.Thread |
newThread(java.lang.Runnable r) |
public KafkaCruiseControlThreadFactory(java.lang.String name, boolean daemon, org.slf4j.Logger logger)
public KafkaCruiseControlThreadFactory(java.lang.String name, boolean daemon, org.slf4j.Logger logger, java.util.Optional<java.lang.Integer> brokerId)