Skip to content

Commit 2ab9bf2

Browse files
committed
minor, process NoSuchMethodError with lower version Kafka consumer
1 parent 8be842e commit 2ab9bf2

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

source-kafka/src/main/java/org/apache/kylin/source/kafka/config/KafkaConsumerProperties.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -79,8 +79,8 @@ public static Properties extractKafkaConfigToProperties(Configuration configurat
7979
Set<String> configNames = new HashSet<String>();
8080
try {
8181
configNames = ConsumerConfig.configNames();
82-
} catch (Exception e) {
83-
// the Kafka configNames api is supported on 0.10.1.0+, in case NoSuchMethodException
82+
} catch (Error e) {
83+
// the Kafka configNames api is supported on 0.10.1.0+, in case NoSuchMethodException which is an Error, not Exception
8484
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,"
8585
+ " 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(",");
8686
configNames.addAll(Arrays.asList(configNamesArray));

0 commit comments

Comments
 (0)