org.darkphoenixs.pool.kafka

类 KafkaSharedConnPool

java.lang.Object

org.darkphoenixs.pool.kafka.KafkaSharedConnPool

所有已实现的接口:

Serializable, ConnectionPool<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>

public class KafkaSharedConnPool
extends Object
implements ConnectionPool<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>

Title: KafkaSharedConnPool

Description: Kafka共享连接池（单例）

从以下版本开始:

2016 /8/23

版本:

1.2.3

作者:

Victor.Zxy

另请参阅:

ConnectionPool, 序列化表格

字段概要

字段

限定符和类型	字段和说明
private static AtomicReference<KafkaSharedConnPool>	pool
private org.apache.kafka.clients.producer.Producer<byte[],byte[]>	producer

构造器概要

构造器

限定符	构造器和说明
private	KafkaSharedConnPool(Properties properties)

方法概要

方法

限定符和类型	方法和说明
void	close() Close.
org.apache.kafka.clients.producer.Producer<byte[],byte[]>	getConnection() Title: getConnection Description: 获取连接
static KafkaSharedConnPool	getInstance(Properties properties) Gets instance.
static KafkaSharedConnPool	getInstance(String brokers, String codec, String keySer, String valSer) Gets instance.
void	invalidateConnection(org.apache.kafka.clients.producer.Producer<byte[],byte[]> conn) Title: invalidateConnection Description: 废弃连接
void	returnConnection(org.apache.kafka.clients.producer.Producer<byte[],byte[]> conn) Title: returnConnection Description: 返回连接

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

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

字段详细资料

pool

private static final AtomicReference<KafkaSharedConnPool> pool

producer

private final org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer

构造器详细资料

KafkaSharedConnPool

private KafkaSharedConnPool(Properties properties)

方法详细资料

getInstance

public static KafkaSharedConnPool getInstance(String brokers,
                              String codec,
                              String keySer,
                              String valSer)

Gets instance.

参数:

brokers - the brokers

codec - the codec

keySer - the key ser

valSer - the val ser

返回:

the instance

getInstance

public static KafkaSharedConnPool getInstance(Properties properties)

Gets instance.

参数:

properties - the properties

返回:

the instance

getConnection

public org.apache.kafka.clients.producer.Producer<byte[],byte[]> getConnection()

从接口复制的说明: ConnectionPool

Title: getConnection

Description: 获取连接

指定者:

getConnection 在接口中 ConnectionPool<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>

返回:

连接

returnConnection

public void returnConnection(org.apache.kafka.clients.producer.Producer<byte[],byte[]> conn)

从接口复制的说明: ConnectionPool

Title: returnConnection

Description: 返回连接

指定者:

returnConnection 在接口中 ConnectionPool<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>

参数:

conn - 连接

invalidateConnection

public void invalidateConnection(org.apache.kafka.clients.producer.Producer<byte[],byte[]> conn)

从接口复制的说明: ConnectionPool

Title: invalidateConnection

Description: 废弃连接

指定者:

invalidateConnection 在接口中 ConnectionPool<org.apache.kafka.clients.producer.Producer<byte[],byte[]>>

参数:

conn - 连接

close

public void close()

Close.