[Kafka Input] Error using Custom Java Assignor class

Elastic Stack Logstash
1

Trying to use a custom assignor in partition_assignment_strategy but getting the following error.

Expectation:
Logstash is able to run without issues as partition_assignment_strategy field still seems to support java classes.

Steps to recreate:

  1. copy kafka/clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java at master · a0x8o/kafka · GitHub and change package name, classname and filename to match.
  2. configure pom.xml to build jar
  3. copy jar to /usr/share/logstash/logstash-core/lib/jars/ where common jars are located
  4. run logstash

Version:

  • Plugin: logstash-integration-kafka-10.12.0-java
  • Logstash: 7.10.2

Logs:

{"level":"ERROR","loggerName":"logstash.inputs.kafka","timeMillis":1708586399192,"thread":"[archiver_cauldron_log]<kafka","logEvent":{"message":"Unable to create Kafka consumer from given configuration","kafka_error_message":{"cause":{"cause":{"stackTrace":[{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","file":"BuiltinClassLoader.java","line":581,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","file":"ClassLoaders.java","line":178,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":522,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"defineClass1","file":"ClassLoader.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"defineClass","file":"ClassLoader.java","line":1017,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.security.SecureClassLoader","method":"defineClass","file":"SecureClassLoader.java","line":174,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"defineClass","file":"BuiltinClassLoader.java","line":800,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"findClassOnClassPathOrNull","file":"BuiltinClassLoader.java","line":698,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClassOrNull","file":"BuiltinClassLoader.java","line":621,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","file":"BuiltinClassLoader.java","line":579,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","file":"ClassLoaders.java","line":178,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":576,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":522,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName0","file":"Class.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName","file":"Class.java","line":398,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.apache.kafka.clients.consumer.internals.PartitionAssignorAdapter","method":"getAssignorInstances","file":"PartitionAssignorAdapter.java","line":113},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":771},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":665},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":646},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":626},{"class":"jdk.internal.reflect.GeneratedConstructorAccessor52","method":"newInstance","line":-1},{"class":"jdk.internal.reflect.DelegatingConstructorAccessorImpl","method":"newInstance","file":"DelegatingConstructorAccessorImpl.java","line":45,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.reflect.Constructor","method":"newInstance","file":"Constructor.java","line":490,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.jruby.javasupport.JavaConstructor","method":"newInstanceDirect","file":"JavaConstructor.java","line":285,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":387,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":185,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$InitializeMethod","method":"call","file":"ConcreteJavaProxy.java","line":56,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":183,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"newInstance","file":"RubyClass.java","line":918,"classLoaderName":"app"},{"class":"org.jruby.RubyClass$INVOKER$i$newInstance","method":"call","file":"RubyClass$INVOKER$i$newInstance.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroOrOneOrNBlock","method":"call","file":"JavaMethod.java","line":349,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$NewMethod","method":"call","file":"ConcreteJavaProxy.java","line":158,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.
...

(will attach full logs in subsequent comment)

2 
PartitionAssignorAdapter","method":"getAssignorInstances","file":"PartitionAssignorAdapter.java","line":113},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":771},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":665},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":646},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":626},{"class":"jdk.internal.reflect.GeneratedConstructorAccessor52","method":"newInstance","line":-1},{"class":"jdk.internal.reflect.DelegatingConstructorAccessorImpl","method":"newInstance","file":"DelegatingConstructorAccessorImpl.java","line":45,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.reflect.Constructor","method":"newInstance","file":"Constructor.java","line":490,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.jruby.javasupport.JavaConstructor","method":"newInstanceDirect","file":"JavaConstructor.java","line":285,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":86,"classLoaderName":"app"},...
{"class":"org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroOrOneOrNBlock","method":"call","file":"JavaMethod.java","line":349,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$NewMethod","method":"call","file":"ConcreteJavaProxy.java","line":158,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther189:new","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$method$create_consumer$0","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"org.jruby.internal.runtime.methods.CompiledIRMethod","method":"call","file":"CompiledIRMethod.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":140,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther1:create_consumer","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$block$run$1","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.runtime.CompiledIRBlockBody","method":"yieldDirect","file":"CompiledIRBlockBody.java","line":148,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yield","file":"Block.java","line":184,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable$22","method":"call","file":"RubyEnumerable.java","line":902,"classLoaderName":"app"},{"class":"org.jruby.runtime.CallBlock19","method":"doYield","file":"CallBlock19.java","line":111,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":117,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yieldValues","file":"Block.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator$2","method":"call","file":"RubyEnumerator.java","line":404,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockCallback","method":"call","file":"BlockCallback.java","line":40,"classLoaderName":"app"},{"class":"org.jruby.runtime.CallBlock","method":"doYield","file":"CallBlock.java","line":96,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":108,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yield","file":"Block.java","line":184,"classLoaderName":"app"},{"class":"org.jruby.RubyFixnum","method":"times","file":"RubyFixnum.java","line":291,"classLoaderName":"app"},{"class":"org.jruby.RubyInteger$INVOKER$i$0$0$times","method":"call","file":"RubyInteger$INVOKER$i$0$0$times.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroBlock","method":"call","file":"JavaMethod.java","line":555,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"RubyClass.java","line":514,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvoke","file":"RubyClass.java","line":502,"classLoaderName":"app"},{"class":"org.jruby.runtime.Helpers","method":"invoke","file":"Helpers.java","line":631,"classLoaderName":"app"},{"class":"org.jruby.RubyBasicObject","method":"callMethod","file":"RubyBasicObject.java","line":393,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator","method":"__each__","file":"RubyEnumerator.java","line":400,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator","method":"each","file":"RubyEnumerator.java","line":396,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator$INVOKER$i$each","method":"call","file":"RubyEnumerator$INVOKER$i$each.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"RubyClass.java","line":497,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvoke","file":"RubyClass.java","line":487,"classLoaderName":"app"},{"class":"org.jruby.runtime.Helpers","method":"invoke","file":"Helpers.java","line":619,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"callEach19","file":"RubyEnumerable.java","line":119,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"collectCommon","file":"RubyEnumerable.java","line":894,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"map","file":"RubyEnumerable.java","line":886,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable$INVOKER$s$0$0$map","method":"call","file":"RubyEnumerable$INVOKER$s$0$0$map.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":152,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"callIter","file":"CachingCallSite.java","line":161,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther7:map","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$method$run$0","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.internal.runtime.methods.CompiledIRMethod","method":"call","file":"CompiledIRMethod.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":140,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"interpret","file":"InterpreterEngine.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"INTERPRET_METHOD","file":"MixedModeIRMethod.java","line":156,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":143,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":376,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.Interpreter","method":"INTERPRET_BLOCK","file":"Interpreter.java","line":116,"classLoaderName":"app"},{"class":"org.jruby.runtime.MixedModeIRBlockBody","method":"commonYieldPath","file":"MixedModeIRBlockBody.java","line":137,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":60,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":52,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"call","file":"Block.java","line":139,"classLoaderName":"app"},{"class":"org.jruby.RubyProc","method":"call","file":"RubyProc.java","line":318,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.RubyRunnable","method":"run","file":"RubyRunnable.java","line":105,"classLoaderName":"app"},{"class":"java.lang.Thread","method":"run","file":"Thread.java","line":829,"moduleName":"java.base","moduleVersion":"11.0.16"}],"message":"org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor","localizedMessage":"org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor"},"stackTrace":[{"class":"java.lang.ClassLoader","method":"defineClass1","file":"ClassLoader.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"defineClass","file":"ClassLoader.java","line":1017,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.security.SecureClassLoader","method":"defineClass","file":"SecureClassLoader.java","line":174,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"defineClass","file":"BuiltinClassLoader.java","line":800,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"findClassOnClassPathOrNull","file":"BuiltinClassLoader.java","line":698,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClassOrNull","file":"BuiltinClassLoader.java","line":621,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","file":"BuiltinClassLoader.java","line":579,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","file":"ClassLoaders.java","line":178,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":576,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":522,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName0","file":"Class.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName","file":"Class.java","line":398,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.apache.kafka.clients.consumer.internals.PartitionAssignorAdapter","method":"getAssignorInstances","file":"PartitionAssignorAdapter.java","line":113},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":771},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":665},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":646},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":626},{"class":"jdk.internal.reflect.GeneratedConstructorAccessor52","method":"newInstance","line":-1},{"class":"jdk.internal.reflect.DelegatingConstructorAccessorImpl","method":"newInstance","file":"DelegatingConstructorAccessorImpl.java","line":45,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.reflect.Constructor","method":"newInstance","file":"Constructor.java","line":490,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.jruby.javasupport.JavaConstructor","method":"newInstanceDirect","file":"JavaConstructor.java","line":285,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":387,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":185,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$InitializeMethod","method":"call","file":"ConcreteJavaProxy.java","line":56,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":183,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"newInstance","file":"RubyClass.java","line":918,"classLoaderName":"app"},{"class":"org.jruby.RubyClass$INVOKER$i$newInstance","method":"call","file":"RubyClass$INVOKER$i$newInstance.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroOrOneOrNBlock","method":"call","file":"JavaMethod.java","line":349,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$NewMethod","method":"call","file":"ConcreteJavaProxy.java","line":158,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther189:new","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$method$create_consumer$0","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"org.jruby.internal.runtime.methods.CompiledIRMethod","method":"call","file":"CompiledIRMethod.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":140,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther1:create_consumer","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$block$run$1","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.runtime.CompiledIRBlockBody","method":"yieldDirect","file":"CompiledIRBlockBody.java","line":148,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yield","file":"Block.java","line":184,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable$22","method":"call","file":"RubyEnumerable.java","line":902,"classLoaderName":"app"},{"class":"org.jruby.runtime.CallBlock19","method":"doYield","file":"CallBlock19.java","line":111,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":117,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yieldValues","file":"Block.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator$2","method":"call","file":"RubyEnumerator.java","line":404,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockCallback","method":"call","file":"BlockCallback.java","line":40,"classLoaderName":"app"},{"class":"org.jruby.runtime.CallBlock","method":"doYield","file":"CallBlock.java","line":96,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":108,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yield","file":"Block.java","line":184,"classLoaderName":"app"},{"class":"org.jruby.RubyFixnum","method":"times","file":"RubyFixnum.java","line":291,"classLoaderName":"app"},{"class":"org.jruby.RubyInteger$INVOKER$i$0$0$times","method":"call","file":"RubyInteger$INVOKER$i$0$0$times.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroBlock","method":"call","file":"JavaMethod.java","line":555,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"RubyClass.java","line":514,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvoke","file":"RubyClass.java","line":502,"classLoaderName":"app"},{"class":"org.jruby.runtime.Helpers","method":"invoke","file":"Helpers.java","line":631,"classLoaderName":"app"},{"class":"org.jruby.RubyBasicObject","method":"callMethod","file":"RubyBasicObject.java","line":393,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator","method":"__each__","file":"RubyEnumerator.java","line":400,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator","method":"each","file":"RubyEnumerator.java","line":396,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator$INVOKER$i$each","method":"call","file":"RubyEnumerator$INVOKER$i$each.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"RubyClass.java","line":497,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvoke","file":"RubyClass.java","line":487,"classLoaderName":"app"},{"class":"org.jruby.runtime.Helpers","method":"invoke","file":"Helpers.java","line":619,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"callEach19","file":"RubyEnumerable.java","line":119,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"collectCommon","file":"RubyEnumerable.java","line":894,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"map","file":"RubyEnumerable.java","line":886,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable$INVOKER$s$0$0$map","method":"call","file":"RubyEnumerable$INVOKER$s$0$0$map.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":152,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"callIter","file":"CachingCallSite.java","line":161,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther7:map","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$method$run$0","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.internal.runtime.methods.CompiledIRMethod","method":"call","file":"CompiledIRMethod.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":140,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"interpret","file":"InterpreterEngine.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"INTERPRET_METHOD","file":"MixedModeIRMethod.java","line":156,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":143,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":376,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.Interpreter","method":"INTERPRET_BLOCK","file":"Interpreter.java","line":116,"classLoaderName":"app"},{"class":"org.jruby.runtime.MixedModeIRBlockBody","method":"commonYieldPath","file":"MixedModeIRBlockBody.java","line":137,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":60,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":52,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"call","file":"Block.java","line":139,"classLoaderName":"app"},{"class":"org.jruby.RubyProc","method":"call","file":"RubyProc.java","line":318,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.RubyRunnable","method":"run","file":"RubyRunnable.java","line":105,"classLoaderName":"app"},{"class":"java.lang.Thread","method":"run","file":"Thread.java","line":829,"moduleName":"java.base","moduleVersion":"11.0.16"}],"message":"org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor","localizedMessage":"org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor"},"stackTrace":[{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"org/apache/kafka/clients/consumer/KafkaConsumer.java","line":823},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"org/apache/kafka/clients/consumer/KafkaConsumer.java","line":665},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"org/apache/kafka/clients/consumer/KafkaConsumer.java","line":646},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"org/apache/kafka/clients/consumer/KafkaConsumer.java","line":626},{"class":"jdk.internal.reflect.GeneratedConstructorAccessor52","method":"newInstance","file":"jdk/internal/reflect/GeneratedConstructorAccessor52","line":-1},{"class":"jdk.internal.reflect.DelegatingConstructorAccessorImpl","method":"newInstance","file":"jdk/internal/reflect/DelegatingConstructorAccessorImpl.java","line":45},{"class":"java.lang.reflect.Constructor","method":"newInstance","file":"java/lang/reflect/Constructor.java","line":490},{"class":"org.jruby.javasupport.JavaConstructor","method":"newInstanceDirect","file":"org/jruby/javasupport/JavaConstructor.java","line":285},{"class":"org.jruby.RubyClass","method":"newInstance","file":"org/jruby/RubyClass.java","line":918},{"class":"org.jruby.RubyClass$INVOKER$i$newInstance","method":"call","file":"org/jruby/RubyClass$INVOKER$i$newInstance.gen","line":-1},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther189:new","file":"usr/share/logstash/vendor/bundle/jruby/$2_dot_5_dot_0/gems/logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java/lib/logstash/inputs//usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"create_consumer","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther1:create_consumer","file":"usr/share/logstash/vendor/bundle/jruby/$2_dot_5_dot_0/gems/logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java/lib/logstash/inputs//usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"run","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.RubyEnumerable$22","method":"call","file":"org/jruby/RubyEnumerable.java","line":902},{"class":"org.jruby.RubyEnumerator$2","method":"call","file":"org/jruby/RubyEnumerator.java","line":404},{"class":"org.jruby.RubyFixnum","method":"times","file":"org/jruby/RubyFixnum.java","line":291},{"class":"org.jruby.RubyInteger$INVOKER$i$0$0$times","method":"call","file":"org/jruby/RubyInteger$INVOKER$i$0$0$times.gen","line":-1},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"org/jruby/RubyClass.java","line":514},{"class":"org.jruby.RubyClass","method":"finvoke","file":"org/jruby/RubyClass.java","line":502},{"class":"org.jruby.RubyBasicObject","method":"callMethod","file":"org/jruby/RubyBasicObject.java","line":393},{"class":"org.jruby.RubyEnumerator","method":"__each__","file":"org/jruby/RubyEnumerator.java","line":400},{"class":"org.jruby.RubyEnumerator","method":"each","file":"org/jruby/RubyEnumerator.java","line":396},{"class":"org.jruby.RubyEnumerator$INVOKER$i$each","method":"call","file":"org/jruby/RubyEnumerator$INVOKER$i$each.gen","line":-1},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"org/jruby/RubyClass.java","line":497},{"class":"org.jruby.RubyClass","method":"finvoke","file":"org/jruby/RubyClass.java","line":487},{"class":"org.jruby.RubyEnumerable","method":"callEach19","file":"org/jruby/RubyEnumerable.java","line":119},{"class":"org.jruby.RubyEnumerable","method":"collectCommon","file":"org/jruby/RubyEnumerable.java","line":894},{"class":"org.jruby.RubyEnumerable","method":"map","file":"org/jruby/RubyEnumerable.java","line":886},{"class":"org.jruby.RubyEnumerable$INVOKER$s$0$0$map","method":"call","file":"org/jruby/RubyEnumerable$INVOKER$s$0$0$map.gen","line":-1},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther7:map","file":"usr/share/logstash/vendor/bundle/jruby/$2_dot_5_dot_0/gems/logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java/lib/logstash/inputs//usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"run","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"RUBY","method":"inputworker","file":"/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb","line":410},{"class":"RUBY","method":"start_input","file":"/usr/share/logstash/logstash-core/lib/logstash/java_pipeline.rb","line":401},{"class":"org.jruby.RubyProc","method":"call","file":"org/jruby/RubyProc.java","line":318},{"class":"java.lang.Thread","method":"run","file":"java/lang/Thread.java","line":829}],"message":"Failed to construct kafka consumer","localizedMessage":"Failed to construct kafka consumer"},"cause":{"cause":{"stackTrace":[{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","file":"BuiltinClassLoader.java","line":581,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","file":"ClassLoaders.java","line":178,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":522,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"defineClass1","file":"ClassLoader.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"defineClass","file":"ClassLoader.java","line":1017,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.security.SecureClassLoader","method":"defineClass","file":"SecureClassLoader.java","line":174,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"defineClass","file":"BuiltinClassLoader.java","line":800,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"findClassOnClassPathOrNull","file":"BuiltinClassLoader.java","line":698,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClassOrNull","file":"BuiltinClassLoader.java","line":621,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","file":"BuiltinClassLoader.java","line":579,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","file":"ClassLoaders.java","line":178,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":576,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":522,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName0","file":"Class.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName","file":"Class.java","line":398,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.apache.kafka.clients.consumer.internals.PartitionAssignorAdapter","method":"getAssignorInstances","file":"PartitionAssignorAdapter.java","line":113},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":771},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":665},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":646},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":626},{"class":"jdk.internal.reflect.GeneratedConstructorAccessor52","method":"newInstance","line":-1},{"class":"jdk.internal.reflect.DelegatingConstructorAccessorImpl","method":"newInstance","file":"DelegatingConstructorAccessorImpl.java","line":45,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.reflect.Constructor","method":"newInstance","file":"Constructor.java","line":490,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.jruby.javasupport.JavaConstructor","method":"newInstanceDirect","file":"JavaConstructor.java","line":285,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":387,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":185,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$InitializeMethod","method":"call","file":"ConcreteJavaProxy.java","line":56,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":183,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"newInstance","file":"RubyClass.java","line":918,"classLoaderName":"app"},{"class":"org.jruby.RubyClass$INVOKER$i$newInstance","method":"call","file":"RubyClass$INVOKER$i$newInstance.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroOrOneOrNBlock","method":"call","file":"JavaMethod.java","line":349,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$NewMethod","method":"call","file":"ConcreteJavaProxy.java","line":158,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther189:new","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$method$create_consumer$0","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":450},{"class":"org.jruby.internal.runtime.methods.CompiledIRMethod","method":"call","file":"CompiledIRMethod.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":140,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther1:create_consumer","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$block$run$1","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.runtime.CompiledIRBlockBody","method":"yieldDirect","file":"CompiledIRBlockBody.java","line":148,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yield","file":"Block.java","line":184,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable$22","method":"call","file":"RubyEnumerable.java","line":902,"classLoaderName":"app"},{"class":"org.jruby.runtime.CallBlock19","method":"doYield","file":"CallBlock19.java","line":111,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":117,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yieldValues","file":"Block.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator$2","method":"call","file":"RubyEnumerator.java","line":404,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockCallback","method":"call","file":"BlockCallback.java","line":40,"classLoaderName":"app"},{"class":"org.jruby.runtime.CallBlock","method":"doYield","file":"CallBlock.java","line":96,"classLoaderName":"app"},{"class":"org.jruby.runtime.BlockBody","method":"yield","file":"BlockBody.java","line":108,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"yield","file":"Block.java","line":184,"classLoaderName":"app"},{"class":"org.jruby.RubyFixnum","method":"times","file":"RubyFixnum.java","line":291,"classLoaderName":"app"},{"class":"org.jruby.RubyInteger$INVOKER$i$0$0$times","method":"call","file":"RubyInteger$INVOKER$i$0$0$times.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.JavaMethod$JavaMethodZeroBlock","method":"call","file":"JavaMethod.java","line":555,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"RubyClass.java","line":514,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvoke","file":"RubyClass.java","line":502,"classLoaderName":"app"},{"class":"org.jruby.runtime.Helpers","method":"invoke","file":"Helpers.java","line":631,"classLoaderName":"app"},{"class":"org.jruby.RubyBasicObject","method":"callMethod","file":"RubyBasicObject.java","line":393,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator","method":"__each__","file":"RubyEnumerator.java","line":400,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator","method":"each","file":"RubyEnumerator.java","line":396,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerator$INVOKER$i$each","method":"call","file":"RubyEnumerator$INVOKER$i$each.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvokeWithRefinements","file":"RubyClass.java","line":497,"classLoaderName":"app"},{"class":"org.jruby.RubyClass","method":"finvoke","file":"RubyClass.java","line":487,"classLoaderName":"app"},{"class":"org.jruby.runtime.Helpers","method":"invoke","file":"Helpers.java","line":619,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"callEach19","file":"RubyEnumerable.java","line":119,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"collectCommon","file":"RubyEnumerable.java","line":894,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable","method":"map","file":"RubyEnumerable.java","line":886,"classLoaderName":"app"},{"class":"org.jruby.RubyEnumerable$INVOKER$s$0$0$map","method":"call","file":"RubyEnumerable$INVOKER$s$0$0$map.gen","line":-1,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":152,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"callIter","file":"CachingCallSite.java","line":161,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther7:map","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$method$run$0","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.internal.runtime.methods.CompiledIRMethod","method":"call","file":"CompiledIRMethod.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":140,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"interpret","file":"InterpreterEngine.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"INTERPRET_METHOD","file":"MixedModeIRMethod.java","line":156,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":143,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":376,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.Interpreter","method":"INTERPRET_BLOCK","file":"Interpreter.java","line":116,"classLoaderName":"app"},{"class":"org.jruby.runtime.MixedModeIRBlockBody","method":"commonYieldPath","file":"MixedModeIRBlockBody.java","line":137,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":60,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":52,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"call","file":"Block.java","line":139,"classLoaderName":"app"},{"class":"org.jruby.RubyProc","method":"call","file":"RubyProc.java","line":318,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.RubyRunnable","method":"run","file":"RubyRunnable.java","line":105,"classLoaderName":"app"},{"class":"java.lang.Thread","method":"run","file":"Thread.java","line":829,"moduleName":"java.base","moduleVersion":"11.0.16"}],"message":"org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor","localizedMessage":"org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor"},"stackTrace":[{"class":"java.lang.ClassLoader","method":"defineClass1","file":"ClassLoader.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"defineClass","file":"ClassLoader.java","line":1017,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.security.SecureClassLoader","method":"defineClass","file":"SecureClassLoader.java","line":174,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"defineClass","file":"BuiltinClassLoader.java","line":800,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"findClassOnClassPathOrNull","file":"BuiltinClassLoader.java","line":698,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClassOrNull","file":"BuiltinClassLoader.java","line":621,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.BuiltinClassLoader","method":"loadClass","file":"BuiltinClassLoader.java","line":579,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"jdk.internal.loader.ClassLoaders$AppClassLoader","method":"loadClass","file":"ClassLoaders.java","line":178,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":576,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.ClassLoader","method":"loadClass","file":"ClassLoader.java","line":522,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName0","file":"Class.java","line":-2,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.Class","method":"forName","file":"Class.java","line":398,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.apache.kafka.clients.consumer.internals.PartitionAssignorAdapter","method":"getAssignorInstances","file":"PartitionAssignorAdapter.java","line":113},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":771},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":665},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":646},{"class":"org.apache.kafka.clients.consumer.KafkaConsumer","method":"<init>","file":"KafkaConsumer.java","line":626},{"class":"jdk.internal.reflect.GeneratedConstructorAccessor52","method":"newInstance","line":-1},{"class":"jdk.internal.reflect.DelegatingConstructorAccessorImpl","method":"newInstance","file":"DelegatingConstructorAccessorImpl.java","line":45,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"java.lang.reflect.Constructor","method":"newInstance","file":"Constructor.java","line":490,"moduleName":"java.base","moduleVersion":"11.0.16"},{"class":"org.jruby.javasupport.JavaConstructor","method":"newInstanceDirect","file":"JavaConstructor.java","line":285,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.java.invokers.ConstructorInvoker","method":"call","file":"ConstructorInvoker.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":387,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":185,"classLoaderName":"app"},{"class":"org.jruby.java.proxies.ConcreteJavaProxy$InitializeMethod","method":"call","file":"ConcreteJavaProxy.java","line":56,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":183,"classLoaderName":"app"},...{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":152,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"callIter","file":"CachingCallSite.java","line":161,"classLoaderName":"app"},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"invokeOther7:map","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"usr.share.logstash.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_kafka_minus_10_dot_12_dot_0_minus_java.lib.logstash.inputs.kafka","method":"RUBY$method$run$0","file":"/usr/share/logstash/vendor/bundle/jruby/2.5.0/gems/logstash-integration-kafka-10.12.0-java/lib/logstash/inputs/kafka.rb","line":288},{"class":"org.jruby.internal.runtime.methods.CompiledIRMethod","method":"call","file":"CompiledIRMethod.java","line":106,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":140,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":173,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"interpret","file":"InterpreterEngine.java","line":86,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"INTERPRET_METHOD","file":"MixedModeIRMethod.java","line":156,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.MixedModeIRMethod","method":"call","file":"MixedModeIRMethod.java","line":143,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.methods.DynamicMethod","method":"call","file":"DynamicMethod.java","line":200,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"cacheAndCall","file":"CachingCallSite.java","line":376,"classLoaderName":"app"},{"class":"org.jruby.runtime.callsite.CachingCallSite","method":"call","file":"CachingCallSite.java","line":175,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.InterpreterEngine","method":"processCall","file":"InterpreterEngine.java","line":316,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.StartupInterpreterEngine","method":"interpret","file":"StartupInterpreterEngine.java","line":72,"classLoaderName":"app"},{"class":"org.jruby.ir.interpreter.Interpreter","method":"INTERPRET_BLOCK","file":"Interpreter.java","line":116,"classLoaderName":"app"},{"class":"org.jruby.runtime.MixedModeIRBlockBody","method":"commonYieldPath","file":"MixedModeIRBlockBody.java","line":137,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":60,"classLoaderName":"app"},{"class":"org.jruby.runtime.IRBlockBody","method":"call","file":"IRBlockBody.java","line":52,"classLoaderName":"app"},{"class":"org.jruby.runtime.Block","method":"call","file":"Block.java","line":139,"classLoaderName":"app"},{"class":"org.jruby.RubyProc","method":"call","file":"RubyProc.java","line":318,"classLoaderName":"app"},{"class":"org.jruby.internal.runtime.RubyRunnable","method":"run","file":"RubyRunnable.java","line":105,"classLoaderName":"app"},{"class":"java.lang.Thread","method":"run","file":"Thread.java","line":829,"moduleName":"java.base","moduleVersion":"11.0.16"}],"message":"org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor","localizedMessage":"org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor"}}}
3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.