程序包 io.github.wooenrico.kafka

类 KafkaUtil

java.lang.Object

io.github.wooenrico.kafka.KafkaUtil

public final class KafkaUtil
extends Object

构造器概要

构造器

构造器	说明
KafkaUtil()

方法概要

修饰符和类型	方法	说明
static Properties	mergeProperties(Properties common, Properties specific)
static ThreadPoolExecutor	newSingleThreadPoolExecutor(String name)
static ThreadPoolExecutor	newThreadPoolExecutor(ExecutorConf executorConf, ThreadFactory threadFactory)
static ThreadPoolExecutor	newThreadPoolExecutor(String name, ExecutorConsumerProperties consumerProperties)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

KafkaUtil

public KafkaUtil()

方法详细资料

mergeProperties

public static Properties mergeProperties(Properties common,
 Properties specific)

newThreadPoolExecutor

public static ThreadPoolExecutor newThreadPoolExecutor(ExecutorConf executorConf,
 ThreadFactory threadFactory)

newThreadPoolExecutor

public static ThreadPoolExecutor newThreadPoolExecutor(String name,
 ExecutorConsumerProperties consumerProperties)

newSingleThreadPoolExecutor

public static ThreadPoolExecutor newSingleThreadPoolExecutor(String name)