Closed tclarke-scottlogic closed 3 years ago
Error: On line:
registerCloseHook(context::addCloseHook, context::removeCloseHook);
with this exception
spstream.api.runner.FailedToStartException: java.lang.BootstrapMethodError: java.lang.NoSuchMethodError: io.vertx.core.Context.removeCloseHook(Lio/vertx/core/Closeable;)Z
Vertx version: 3.4.2 Vertx-Kafka version: 3.9.4
Constructing a Consumer:
props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, m_server); props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName()); props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class.getName()); props.put(ConsumerConfig.GROUP_ID_CONFIG, m_groupId); props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false"); props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "1"); props.put(ProducerConfig.BATCH_SIZE_CONFIG, 16384); props.put("ack", "all"); // todo: what is that? props.put("security.protocol", "SASL_PLAINTEXT"); props.put("sasl.mechanism", "GSSAPI"); props.put("sasl.kerberos.service.name", "kafka"); props.put("sasl.kerberos.kinit.cmd", "H:\\jdk\\8x64-latest\\jre\\bin"); props.put("sasl.jaas.config", "com.sun.security.auth.module.Krb5LoginModule required " + "debug=true " + "useKeyTab=true " + "storeKey=true " + "keyTab=\"C:/Users/TEMP/krb5.keytab\" " + "principal=\"email@Email.com\";"); myConsumer = KafkaConsumer.create(m_vertx, props);
do you have a reproducer project ?
it looks like a classpath issue
Error: On line:
with this exception
Version
Vertx version: 3.4.2 Vertx-Kafka version: 3.9.4
Context
Constructing a Consumer: