Repository: kylin Updated Branches: refs/heads/yang23 25574f8a3 -> ecdcf3a14
minor, process NoSuchMethodError with lower version Kafka consumer Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/ecdcf3a1 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/ecdcf3a1 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/ecdcf3a1 Branch: refs/heads/yang23 Commit: ecdcf3a14e3f44b32a89650eb2076d2545eb1124 Parents: 25574f8 Author: Billy Liu <billy...@apache.org> Authored: Wed Mar 15 21:03:47 2017 -0700 Committer: Billy Liu <billy...@apache.org> Committed: Wed Mar 15 21:04:43 2017 -0700 ---------------------------------------------------------------------- .../kylin/source/kafka/config/KafkaConsumerProperties.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/ecdcf3a1/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaConsumerProperties.java ---------------------------------------------------------------------- diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaConsumerProperties.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaConsumerProperties.java index 5b3dd87..cc32ed9 100644 --- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaConsumerProperties.java +++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaConsumerProperties.java @@ -79,8 +79,8 @@ public class KafkaConsumerProperties { Set<String> configNames = new HashSet<String>(); try { configNames = ConsumerConfig.configNames(); - } catch (Exception e) { - // the Kafka configNames api is supported on 0.10.1.0+, in case NoSuchMethodException + } catch (Error e) { + // the Kafka configNames api is supported on 0.10.1.0+, in case NoSuchMethodException which is an Error, not Exception String[] configNamesArray = ("metric.reporters, metadata.max.age.ms, partition.assignment.strategy, reconnect.backoff.ms," + "sasl.kerberos.ticket.renew.window.factor, max.partition.fetch.bytes, bootstrap.servers, ssl.keystore.type," + " enable.auto.commit, sasl.mechanism, interceptor.classes, exclude.internal.topics, ssl.truststore.password," + " client.id, ssl.endpoint.identification.algorithm, max.poll.records, check.crcs, request.timeout.ms, heartbeat.interval.ms," + " auto.commit.interval.ms, receive.buffer.bytes, ssl.truststore.type, ssl.truststore.location, ssl.keystore.password, fetch.min.bytes," + " fetch.max.bytes, send.buffer.bytes, max.poll.interval.ms, value.deserializer, group.id, retry.backoff.ms," + " ssl.secure.random.implementation, sasl.kerberos.kinit.cmd, sasl.kerberos.service.name, sasl.kerberos.ticket.renew.jitter, ssl.trustmanager.algorithm, ssl.key.password, fetch.max.wait.ms, sasl.kerberos.min.time.before.relogin, connections.max.idle.ms, session.timeout.ms, metrics.num.samples, key.deserializer, ssl.protocol, ssl.provider, ssl.enabled.protocols, ssl.keystore.location, ssl.cipher.suites, security.protocol, ssl.keymanager.algorithm, metrics.sample.window.ms, auto.offset.reset").split(","); configNames.addAll(Arrays.asList(configNamesArray));
