org.apache.shenyu.plugin.logging.kafka.config

类 KafkaLogCollectConfig.KafkaLogConfig

java.lang.Object

org.apache.shenyu.plugin.logging.common.config.GenericGlobalConfig

org.apache.shenyu.plugin.logging.kafka.config.KafkaLogCollectConfig.KafkaLogConfig

封闭类:

KafkaLogCollectConfig

public static class KafkaLogCollectConfig.KafkaLogConfig
extends org.apache.shenyu.plugin.logging.common.config.GenericGlobalConfig

global log config.

构造器概要

构造器

构造器和说明
KafkaLogConfig()

方法概要

限定符和类型	方法和说明
boolean	equals(java.lang.Object o)
java.lang.String	getCompressAlg() whether compress.
java.lang.String	getNamesrvAddr() get kafka nameserver address.
java.lang.String	getPassWord() get kafka passWord.
java.lang.String	getProducerGroup() get producer group.
java.lang.String	getSaslMechanism() get Kafka saslMechanism.
java.lang.String	getSecurityProtocol() get kafka securityProtocol.
java.lang.String	getTopic() get message queue topic.
java.lang.String	getUserName() get kafka userName.
int	hashCode()
void	setCompressAlg(java.lang.String compressAlg) set compress.
void	setNamesrvAddr(java.lang.String namesrvAddr) set kafka nameserver address.
void	setPassWord(java.lang.String passWord) set kafka pwd.
void	setProducerGroup(java.lang.String producerGroup) set producer group.
void	setSaslMechanism(java.lang.String saslMechanism) set kafka saslMechanism.
void	setSecurityProtocol(java.lang.String securityProtocol) set kafka securityProtocol.
void	setTopic(java.lang.String topic) topic,used for message queue.
void	setUserName(java.lang.String userName) set kafka userName.

从类继承的方法 org.apache.shenyu.plugin.logging.common.config.GenericGlobalConfig

getBufferQueueSize, getMaxRequestBody, getMaxResponseBody, getSampler, getSampleRate, setBufferQueueSize, setMaxRequestBody, setMaxResponseBody, setSampler, setSampleRate

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

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

构造器详细资料

KafkaLogConfig

public KafkaLogConfig()

方法详细资料

getSecurityProtocol

public java.lang.String getSecurityProtocol()

get kafka securityProtocol.

返回:

securityProtocol

setSecurityProtocol

public void setSecurityProtocol(java.lang.String securityProtocol)

set kafka securityProtocol.

参数:

securityProtocol - securityProtocol

getSaslMechanism

public java.lang.String getSaslMechanism()

get Kafka saslMechanism.

返回:

saslMechanism

setSaslMechanism

public void setSaslMechanism(java.lang.String saslMechanism)

set kafka saslMechanism.

参数:

saslMechanism - saslMechanism

getUserName

public java.lang.String getUserName()

get kafka userName.

返回:

userName

setUserName

public void setUserName(java.lang.String userName)

set kafka userName.

参数:

userName - userName

getPassWord

public java.lang.String getPassWord()

get kafka passWord.

返回:

passWord

setPassWord

public void setPassWord(java.lang.String passWord)

set kafka pwd.

参数:

passWord - passWord

getCompressAlg

public java.lang.String getCompressAlg()

whether compress.

返回:

compress or not

setCompressAlg

public void setCompressAlg(java.lang.String compressAlg)

set compress.

参数:

compressAlg - compress alg.

getTopic

public java.lang.String getTopic()

get message queue topic.

返回:

message queue topic

setTopic

public void setTopic(java.lang.String topic)

topic,used for message queue.

参数:

topic - mq topic

getNamesrvAddr

public java.lang.String getNamesrvAddr()

get kafka nameserver address.

返回:

kafka nameserver address

setNamesrvAddr

public void setNamesrvAddr(java.lang.String namesrvAddr)

set kafka nameserver address.

参数:

namesrvAddr - kafka nameserver address

getProducerGroup

public java.lang.String getProducerGroup()

get producer group.

返回:

producer group

setProducerGroup

public void setProducerGroup(java.lang.String producerGroup)

set producer group.

参数:

producerGroup - producer group

equals

public boolean equals(java.lang.Object o)

覆盖:

equals 在类中 java.lang.Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 java.lang.Object