程序包 io.github.wooenrico.kafka

类 KafkaProperties

java.lang.Object

io.github.wooenrico.kafka.KafkaProperties

public class KafkaProperties
extends Object

构造器概要

构造器

构造器	说明
KafkaProperties()

方法概要

修饰符和类型	方法	说明
Properties	getCommonConsumerProperties()
Properties	getCommonSenderProperties()
Map<String,BeanNameRateLimitExecutorConsumerProperties>	getConsumer()
BeanNameRateLimitExecutorConsumerProperties	getConsumerProperties(String key)
Set<String>	getConsumerSet()
Map<String,SenderProperties>	getSender()
SenderProperties	getSenderProperties(String key)
Set<String>	getSenderSet()
void	setCommonConsumerProperties(Properties commonConsumerProperties)
void	setCommonSenderProperties(Properties commonSenderProperties)
void	setConsumer(Map<String,BeanNameRateLimitExecutorConsumerProperties> consumer)
void	setSender(Map<String,SenderProperties> sender)

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

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

构造器详细资料

KafkaProperties

public KafkaProperties()

方法详细资料

getCommonSenderProperties

public Properties getCommonSenderProperties()

setCommonSenderProperties

public void setCommonSenderProperties(Properties commonSenderProperties)

getCommonConsumerProperties

public Properties getCommonConsumerProperties()

setCommonConsumerProperties

public void setCommonConsumerProperties(Properties commonConsumerProperties)

getSender

public Map<String,SenderProperties> getSender()

setSender

public void setSender(Map<String,SenderProperties> sender)

getConsumer

public Map<String,BeanNameRateLimitExecutorConsumerProperties> getConsumer()

setConsumer

public void setConsumer(Map<String,BeanNameRateLimitExecutorConsumerProperties> consumer)

getSenderSet

public Set<String> getSenderSet()

getSenderProperties

public SenderProperties getSenderProperties(String key)

getConsumerSet

public Set<String> getConsumerSet()

getConsumerProperties

public BeanNameRateLimitExecutorConsumerProperties getConsumerProperties(String key)