public class KafkaLog4jAppender
extends org.apache.log4j.AppenderSkeleton
Constructor and Description |
---|
KafkaLog4jAppender() |
Modifier and Type | Method and Description |
---|---|
void |
activateOptions() |
protected void |
append(org.apache.log4j.spi.LoggingEvent event) |
void |
close() |
java.lang.String |
getBrokerList() |
java.lang.String |
getCompressionType() |
protected org.apache.kafka.clients.producer.Producer<byte[],byte[]> |
getKafkaProducer(java.util.Properties props) |
org.apache.kafka.clients.producer.Producer<byte[],byte[]> |
getProducer() |
int |
getRequiredNumAcks() |
int |
getRetries() |
java.lang.String |
getSecurityProtocol() |
java.lang.String |
getSslKeystoreLocation() |
java.lang.String |
getSslKeystorePassword() |
java.lang.String |
getSslKeystoreType() |
java.lang.String |
getSslTruststoreLocation() |
java.lang.String |
getSslTruststorePassword() |
boolean |
getSyncSend() |
java.lang.String |
getTopic() |
boolean |
requiresLayout() |
void |
setBrokerList(java.lang.String brokerList) |
void |
setCompressionType(java.lang.String compressionType) |
void |
setRequiredNumAcks(int requiredNumAcks) |
void |
setRetries(int retries) |
void |
setSecurityProtocol(java.lang.String securityProtocol) |
void |
setSslKeystoreLocation(java.lang.String sslKeystoreLocation) |
void |
setSslKeystorePassword(java.lang.String sslKeystorePassword) |
void |
setSslKeystoreType(java.lang.String sslKeystoreType) |
void |
setSslTruststoreLocation(java.lang.String sslTruststoreLocation) |
void |
setSslTruststorePassword(java.lang.String sslTruststorePassword) |
void |
setSyncSend(boolean syncSend) |
void |
setTopic(java.lang.String topic) |
public org.apache.kafka.clients.producer.Producer<byte[],byte[]> getProducer()
public java.lang.String getBrokerList()
public void setBrokerList(java.lang.String brokerList)
public int getRequiredNumAcks()
public void setRequiredNumAcks(int requiredNumAcks)
public int getRetries()
public void setRetries(int retries)
public java.lang.String getCompressionType()
public void setCompressionType(java.lang.String compressionType)
public java.lang.String getTopic()
public void setTopic(java.lang.String topic)
public boolean getSyncSend()
public void setSyncSend(boolean syncSend)
public java.lang.String getSslTruststorePassword()
public java.lang.String getSslTruststoreLocation()
public java.lang.String getSecurityProtocol()
public void setSecurityProtocol(java.lang.String securityProtocol)
public void setSslTruststoreLocation(java.lang.String sslTruststoreLocation)
public void setSslTruststorePassword(java.lang.String sslTruststorePassword)
public void setSslKeystorePassword(java.lang.String sslKeystorePassword)
public void setSslKeystoreType(java.lang.String sslKeystoreType)
public void setSslKeystoreLocation(java.lang.String sslKeystoreLocation)
public java.lang.String getSslKeystoreLocation()
public java.lang.String getSslKeystoreType()
public java.lang.String getSslKeystorePassword()
public void activateOptions()
activateOptions
in interface org.apache.log4j.spi.OptionHandler
activateOptions
in class org.apache.log4j.AppenderSkeleton
protected org.apache.kafka.clients.producer.Producer<byte[],byte[]> getKafkaProducer(java.util.Properties props)
protected void append(org.apache.log4j.spi.LoggingEvent event)
append
in class org.apache.log4j.AppenderSkeleton
public void close()
public boolean requiresLayout()