Hi,
My logstash config looks like
input {
azure_event_hubs {
config_mode => "basic"
event_hub_connections => ["Endpoint=sb://audit-ops-logs.servicebus.windows.net/;SharedAccessKeyName=azure-ls;SharedAccessKey=xxxxxx=;EntityPath=insights-operational-logs"]
threads => 4
decorate_events => true
consumer_group => "ls"
storage_container => "testauditazurediag"
storage_connection => "DefaultEndpointsProtocol=https;AccountName=testauditazurediag;AccountKey=xxx;EndpointSuffix=core.windows.net"
}
}filter {
if [type] == "azure_event_hub" {
json {
source => "message"
}
split {
field => ["records"]
}
}
}output {
elasticsearch {
hosts => ["http://127.0.0.1:9200"]
index => "logstash-azure-%{+YYYY.MM.dd}"
user => "logstash_internal"
password => "elk#123"
#document_type => "%{[@metadata][type]}"
document_type => "azure_audit"
}
stdout
{
codec => rubydebug
}
}
on running i get following o/p
n], condition[Error{condition=null, description='null', info=null}]
[2019-08-14T12:09:26,800][ERROR][logstash.inputs.azureeventhubs] Event Hub failed during initialization. {:event_hub_name=>"insights-operational-logs", :exception=>java.util.concurrent.ExecutionException: org.jruby.exceptions.NoMethodError: (NoMethodError) undefined method `getEventHubPath' for #Java::ComMicrosoftAzureEventprocessorhost::HostContext:0x1acc9f37, :backtrace=>["java.util.concurrent.CompletableFuture.reportGet(java/util/concurrent/CompletableFuture.java:395)", "java.util.concurrent.CompletableFuture.get(java/util/concurrent/CompletableFuture.java:2070)", "jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)", "jdk.internal.reflect.NativeMethodAccessorImpl.invoke(jdk/internal/reflect/NativeMethodAccessorImpl.java:62)", "jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(jdk/internal/reflect/DelegatingMethodAccessorImpl.java:43)", "java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:567)", "org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(org/jruby/javasupport/JavaMethod.java:425)", "org.jruby.javasupport.JavaMethod.invokeDirect(org/jruby/javasupport/JavaMethod.java:292)", "root.logstash_minus_7_dot_1_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_input_minus_azure_event_hubs_minus_1_dot_1_dot_1.lib.logstash.inputs.azure_event_hubs.run(/root/logstash-7.1.1/vendor/bundle/jruby/2.5.0/gems/logstash-input-azure_event_hubs-1.1.1/lib/logstash/inputs/azure_event_hubs.rb:430)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:295)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:274)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:270)", "java.lang.Thread.run(java/lang/Thread.java:835)"]}
This seems to be java related, and not an configuration issue. Any help? Thanks