Repository: kafka Updated Branches: refs/heads/trunk d21cb66e7 -> 8bc59a3b8
MINOR: Fix compiler error in `KafkaLog4jAppender` The branch wasn't rebased after the capitalisation fix for SSL classes. Author: Ismael Juma <[email protected]> Reviewers: Gwen Shapira Closes #368 from ijuma/fix-kafka-log4j-appender-compiler-error Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8bc59a3b Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8bc59a3b Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8bc59a3b Branch: refs/heads/trunk Commit: 8bc59a3b8f29854b8c7178609b99d7c9491886dc Parents: d21cb66 Author: Ismael Juma <[email protected]> Authored: Tue Oct 27 10:00:01 2015 -0700 Committer: Gwen Shapira <[email protected]> Committed: Tue Oct 27 10:00:01 2015 -0700 ---------------------------------------------------------------------- .../apache/kafka/log4jappender/KafkaLog4jAppender.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/8bc59a3b/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java ---------------------------------------------------------------------- diff --git a/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java b/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java index 94120e2..dbbee3c 100644 --- a/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java +++ b/log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java @@ -24,7 +24,7 @@ import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.producer.RecordMetadata; import org.apache.kafka.common.config.ConfigException; -import org.apache.kafka.common.config.SSLConfigs; +import org.apache.kafka.common.config.SslConfigs; import org.apache.log4j.AppenderSkeleton; import org.apache.log4j.helpers.LogLog; import org.apache.log4j.spi.LoggingEvent; @@ -46,11 +46,11 @@ public class KafkaLog4jAppender extends AppenderSkeleton { private static final String KEY_SERIALIZER_CLASS_CONFIG = ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG; private static final String VALUE_SERIALIZER_CLASS_CONFIG = ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG; private static final String SECURITY_PROTOCOL = CommonClientConfigs.SECURITY_PROTOCOL_CONFIG; - private static final String SSL_TRUSTSTORE_LOCATION = SSLConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG; - private static final String SSL_TRUSTSTORE_PASSWORD = SSLConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG; - private static final String SSL_KEYSTORE_TYPE = SSLConfigs.SSL_KEYSTORE_TYPE_CONFIG; - private static final String SSL_KEYSTORE_LOCATION = SSLConfigs.SSL_KEYSTORE_LOCATION_CONFIG; - private static final String SSL_KEYSTORE_PASSWORD = SSLConfigs.SSL_KEYSTORE_PASSWORD_CONFIG; + private static final String SSL_TRUSTSTORE_LOCATION = SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG; + private static final String SSL_TRUSTSTORE_PASSWORD = SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG; + private static final String SSL_KEYSTORE_TYPE = SslConfigs.SSL_KEYSTORE_TYPE_CONFIG; + private static final String SSL_KEYSTORE_LOCATION = SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG; + private static final String SSL_KEYSTORE_PASSWORD = SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG; private String brokerList = null; private String topic = null;
