Remove unused adal4j, refresh consuming dependencies by mashhurs · Pull Request #107 · logstash-plugins/logstash-input-azure_event_hubs

mashhurs · 2025-12-10T01:28:40Z

Description

With #113 PR, I have observed that adal4j dependency isn't loaded unless we change the source code to utilize the ADA (Active Directory Auth) feature.
That indicates we don't need to include ada;4j in the package, which LS artifact will not be also carrying.

This PR

excludes adal4j dependency group to avoid consuming it and its transitive dependencies
updates fresh jar-dependency list in the logstash-input-azure_event_hubs.rb file
version bumps and adds changelog for the release

Testing

Test logs:

~/Dev/elastic/logstash (upstream-main*) » bin/logstash -f config/tests/azure-event-hubs.conf --enable-local-plugin-development                                                      130 ↵ mashhur@Miks-M4
Using system java: /usr/bin/java
Sending Logstash logs to /Users/mashhur/Dev/elastic/logstash/logs which is now configured via log4j2.properties
[2026-01-20T16:13:59,254][INFO ][logstash.runner          ] Log4j configuration path used is: /Users/mashhur/Dev/elastic/logstash/config/log4j2.properties
[2026-01-20T16:13:59,256][WARN ][deprecation.logstash.runner] The use of JAVA_HOME has been deprecated. Logstash 8.0 and later ignores JAVA_HOME and uses the bundled JDK. Running Logstash with the bundled JDK is recommended. The bundled JDK has been verified to work with each specific version of Logstash, and generally provides best performance and reliability. If you have compelling reasons for using your own JDK (organizational-specific compliance requirements, for example), you can configure LS_JAVA_HOME to use that version instead.
[2026-01-20T16:13:59,256][INFO ][logstash.runner          ] Starting Logstash {"logstash.version"=>"9.4.0", "jruby.version"=>"jruby 9.4.13.0 (3.1.4) 2025-06-10 9938a3461f OpenJDK 64-Bit Server VM 21.0.8+9-LTS on 21.0.8+9-LTS +indy +jit [arm64-darwin]"}
[2026-01-20T16:13:59,257][INFO ][logstash.runner          ] JVM bootstrap flags: [-Xms1g, -Xmx1g, -Djava.awt.headless=true, -Dfile.encoding=UTF-8, -XX:+HeapDumpOnOutOfMemoryError, -Djava.security.egd=file:/dev/urandom, -Djruby.regexp.interruptible=true, -Djruby.compile.invokedynamic=true, -Djdk.io.File.enableADS=true, -Dlog4j2.isThreadContextMapInheritable=true, --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED, --add-exports=jdk.compiler/com.sun.tools.javac.file=ALL-UNNAMED, --add-exports=jdk.compiler/com.sun.tools.javac.parser=ALL-UNNAMED, --add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED, --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED, --add-opens=java.base/java.security=ALL-UNNAMED, --add-opens=java.base/java.io=ALL-UNNAMED, --add-opens=java.base/java.nio.channels=ALL-UNNAMED, --add-opens=java.base/sun.nio.ch=ALL-UNNAMED, --add-opens=java.management/sun.management=ALL-UNNAMED, -Dio.netty.allocator.maxOrder=11]
[2026-01-20T16:13:59,268][INFO ][org.logstash.jackson.StreamReadConstraintsUtil] Jackson default value override `logstash.jackson.stream-read-constraints.max-string-length` configured to `200000000` (logstash default)
[2026-01-20T16:13:59,268][INFO ][org.logstash.jackson.StreamReadConstraintsUtil] Jackson default value override `logstash.jackson.stream-read-constraints.max-number-length` configured to `10000` (logstash default)
[2026-01-20T16:13:59,268][INFO ][org.logstash.jackson.StreamReadConstraintsUtil] Jackson default value override `logstash.jackson.stream-read-constraints.max-nesting-depth` configured to `1000` (logstash default)
[2026-01-20T16:13:59,278][WARN ][logstash.config.source.multilocal] Ignoring the 'pipelines.yml' file because command line options are specified
[2026-01-20T16:13:59,475][INFO ][logstash.agent           ] Successfully started Logstash API endpoint {:port=>9600, :ssl_enabled=>false}
[2026-01-20T16:13:59,563][INFO ][org.reflections.Reflections] Reflections took 37 ms to scan 1 urls, producing 163 keys and 559 values
[2026-01-20T16:13:59,630][INFO ][logstash.codecs.json     ] ECS compatibility is enabled but `target` option was not specified. This may cause fields to be set at the top-level of the event where they are likely to clash with the Elastic Common Schema. It is recommended to set the `target` option to avoid potential schema conflicts (if your data is ECS compliant or non-conflicting, feel free to ignore this message)
[2026-01-20T16:13:59,634][WARN ][deprecation.logstash.inputs.azureeventhubs] Codec instantiated by `Config::Mixin::DSL::validate_value(String, :codec)` which cannot propagate parent plugin's execution context or metrics. 
[2026-01-20T16:13:59,636][INFO ][logstash.codecs.json     ] ECS compatibility is enabled but `target` option was not specified. This may cause fields to be set at the top-level of the event where they are likely to clash with the Elastic Common Schema. It is recommended to set the `target` option to avoid potential schema conflicts (if your data is ECS compliant or non-conflicting, feel free to ignore this message)
[2026-01-20T16:13:59,677][INFO ][logstash.javapipeline    ][main] Pipeline `main` is configured with `pipeline.ecs_compatibility: v8` setting. All plugins in this pipeline will default to `ecs_compatibility => v8` unless explicitly configured otherwise.
[2026-01-20T16:13:59,685][INFO ][logstash.javapipeline    ][main] Starting pipeline {:pipeline_id=>"main", "pipeline.workers"=>12, "pipeline.batch.size"=>125, "pipeline.batch.delay"=>50, "pipeline.max_inflight"=>1500, "batch_metric_sampling"=>"minimal", "pipeline.sources"=>["/Users/mashhur/Dev/elastic/logstash/config/tests/azure-event-hubs.conf"], :thread=>"#<Thread:0x6ff5ea34 /Users/mashhur/Dev/elastic/logstash/logstash-core/lib/logstash/java_pipeline.rb:147 run>"}
[2026-01-20T16:13:59,867][INFO ][logstash.javapipeline    ][main] Pipeline Java execution initialization time {"seconds"=>0.18}
[2026-01-20T16:13:59,869][INFO ][logstash.javapipeline    ][main] Pipeline started {"pipeline.id"=>"main"}
[2026-01-20T16:13:59,870][INFO ][logstash.inputs.azureeventhubs][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Event Hub logstash-demo-eventhub is initializing... 
[2026-01-20T16:13:59,873][INFO ][logstash.agent           ] Pipelines running {:count=>1, :running_pipelines=>[:main], :non_running_pipelines=>[]}
[2026-01-20T16:13:59,874][INFO ][com.microsoft.azure.eventprocessorhost.EventProcessorHost][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: New EventProcessorHost created.
[2026-01-20T16:13:59,891][INFO ][com.microsoft.azure.eventprocessorhost.EventProcessorHost][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: Starting event processing.
[2026-01-20T16:13:59,899][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Watchdog is OFF
[2026-01-20T16:13:59,899][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_759f40_1768954439894], hostName[logstash-input-eventhubs.servicebus.windows.net], info[starting reactor instance.]
[2026-01-20T16:13:59,901][INFO ][com.microsoft.azure.eventhubs.impl.ReactorHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] name[MF_759f40_1768954439894] reactor.onReactorInit
[2026-01-20T16:13:59,902][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionInit hostname[logstash-input-eventhubs.servicebus.windows.net], connectionId[MF_759f40_1768954439894]
[2026-01-20T16:13:59,902][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionLocalOpen hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_759f40_1768954439894], errorCondition[null], errorDescription[null]
[2026-01-20T16:13:59,924][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionBound hostname[logstash-input-eventhubs.servicebus.windows.net], connectionId[MF_759f40_1768954439894]
[2026-01-20T16:14:00,355][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionRemoteOpen hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_759f40_1768954439894], remoteContainer[e55f773f55d0485b976303aa71a51866_G53]
[2026-01-20T16:14:00,363][INFO ][com.microsoft.azure.eventhubs.impl.FaultTolerantObject][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] FaultTolerantObject[FTO_366c76_1768954440361] client[MF_759f40_1768954439894] session[mgmt-session] decided to create cNIO[F] innerObject[null] iOstate[--]
[2026-01-20T16:14:00,364][INFO ][com.microsoft.azure.eventhubs.impl.RequestResponseOpener][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] clientId[MF_759f40_1768954439894] rro[RRO_ee6fe3_1768954440361] opening inner channel
[2026-01-20T16:14:00,364][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_759f40_1768954439894], hostName[logstash-input-eventhubs.servicebus.windows.net], getting a session.
[2026-01-20T16:14:00,368][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionLocalOpen connectionId[MF_759f40_1768954439894], entityName[mgmt-session], condition[Error{condition=null, description='null', info=null}]
[2026-01-20T16:14:00,370][INFO ][com.microsoft.azure.eventhubs.impl.SendLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen senderName[mgmt], linkName[mgmt:sender], localTarget[Target{address='$management', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}]
[2026-01-20T16:14:00,370][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen receiverName[mgmt], linkName[mgmt:receiver], localSource[Source{address='$management', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:00,477][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionRemoteOpen connectionId[MF_759f40_1768954439894], entityName[mgmt-session], sessionIncCapacity[0], sessionOutgoingWindow[2147483647]
[2026-01-20T16:14:00,478][INFO ][com.microsoft.azure.eventhubs.impl.SendLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen senderName[mgmt], linkName[mgmt:sender], remoteTarget[Target{address='$management', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}]
[2026-01-20T16:14:00,478][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen receiverName[mgmt], linkName[mgmt:receiver], remoteSource[Source{address='$management', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:00,484][INFO ][com.microsoft.azure.eventhubs.impl.FaultTolerantObject][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] FaultTolerantObject[FTO_366c76_1768954440361] client[MF_759f40_1768954439894] session[mgmt-session] inner object rrc[RRC_cdc8ca_1768954440365] creation complete
[2026-01-20T16:14:00,485][INFO ][com.microsoft.azure.eventhubs.impl.RequestResponseOpener][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] requestResponseChannel.onOpen complete clientId[MF_759f40_1768954439894], session[mgmt-session], link[mgmt], endpoint[$management], rrc[RRC_cdc8ca_1768954440365]
[2026-01-20T16:14:00,572][INFO ][com.microsoft.azure.eventprocessorhost.PartitionManager][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: Eventhub logstash-demo-eventhub count of partitions: 2
[2026-01-20T16:14:00,572][INFO ][com.microsoft.azure.eventprocessorhost.PartitionManager][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: Found partition with id: 0
[2026-01-20T16:14:00,572][INFO ][com.microsoft.azure.eventprocessorhost.PartitionManager][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: Found partition with id: 1
[2026-01-20T16:14:00,573][INFO ][com.microsoft.azure.eventhubs.impl.ClientEntity][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] close: clientId[EC_580f21_1768954439892]
[2026-01-20T16:14:00,573][INFO ][com.microsoft.azure.eventhubs.impl.ClientEntity][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] close: clientId[MF_759f40_1768954439894]
[2026-01-20T16:14:00,577][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionLocalClose hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_759f40_1768954439894], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,579][INFO ][com.microsoft.azure.eventhubs.impl.BaseLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalClose clientName[mgmt], linkName[mgmt:sender], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,579][INFO ][com.microsoft.azure.eventhubs.impl.BaseLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] closeSession for clientName[mgmt], linkName[mgmt:sender], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,579][INFO ][com.microsoft.azure.eventhubs.impl.BaseLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalClose clientName[mgmt], linkName[mgmt:receiver], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,579][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionLocalClose connectionId[mgmt-session], entityName[MF_759f40_1768954439894], condition[Error{condition=null, description='null', info=null}]
[2026-01-20T16:14:00,663][INFO ][com.microsoft.azure.eventhubs.impl.BaseLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteClose clientName[mgmt], linkName[mgmt:sender], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,663][INFO ][com.microsoft.azure.eventhubs.impl.BaseLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] processOnClose clientName[mgmt], linkName[mgmt:sender], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,663][INFO ][com.microsoft.azure.eventhubs.impl.BaseLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteClose clientName[mgmt], linkName[mgmt:receiver], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,663][INFO ][com.microsoft.azure.eventhubs.impl.BaseLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] processOnClose clientName[mgmt], linkName[mgmt:receiver], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,664][INFO ][com.microsoft.azure.eventhubs.impl.RequestResponseOpener][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] requestResponseChannel.onClose complete clientId[MF_759f40_1768954439894], session[mgmt-session], link[mgmt], endpoint[$management], rrc[RRC_cdc8ca_1768954440365]
[2026-01-20T16:14:00,664][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_759f40_1768954439894], hostName[logstash-input-eventhubs.servicebus.windows.net], info[mgmtChannel closed]
[2026-01-20T16:14:00,664][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionRemoteClose hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_759f40_1768954439894], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,664][WARN ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionError messagingFactory[MF_759f40_1768954439894], hostname[logstash-input-eventhubs.servicebus.windows.net], error[null]
[2026-01-20T16:14:00,664][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onTransportClosed hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_759f40_1768954439894], error[n/a]
[2026-01-20T16:14:00,664][INFO ][com.microsoft.azure.eventhubs.impl.CustomIOHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onTransportClosed name[MF_759f40_1768954439894], hostname[logstash-input-eventhubs.servicebus.windows.net:5671]
[2026-01-20T16:14:00,665][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionUnbound hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_759f40_1768954439894], state[CLOSED], remoteState[CLOSED]
[2026-01-20T16:14:00,665][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionFinal connectionId[MF_759f40_1768954439894], entityName[mgmt-session], condition[null], description[null]
[2026-01-20T16:14:00,665][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionFinal hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_759f40_1768954439894], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:00,665][WARN ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_759f40_1768954439894], hostName[logstash-input-eventhubs.servicebus.windows.net], message[stopping the reactor because thread was interrupted or the reactor has no more events to process.]
[2026-01-20T16:14:00,883][INFO ][com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: Created lease store OK or it already existed
[2026-01-20T16:14:01,032][INFO ][logstash.inputs.azureeventhubs][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Event Hub registration complete.  {:event_hub_name=>"logstash-demo-eventhub"}
[2026-01-20T16:14:01,033][INFO ][logstash.inputs.azureeventhubs][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Event Hub is processing events...  {:event_hub_name=>"logstash-demo-eventhub"}
[2026-01-20T16:14:01,779][INFO ][com.microsoft.azure.eventprocessorhost.PumpManager][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 1: creating new pump
[2026-01-20T16:14:01,785][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 1: Creating and opening event processor instance
[2026-01-20T16:14:01,792][INFO ][logstash.codecs.json     ][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] ECS compatibility is enabled but `target` option was not specified. This may cause fields to be set at the top-level of the event where they are likely to clash with the Elastic Common Schema. It is recommended to set the `target` option to avoid potential schema conflicts (if your data is ECS compliant or non-conflicting, feel free to ignore this message)
[2026-01-20T16:14:01,794][INFO ][logstash.inputs.azure.processor][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Event Hub: logstash-demo-eventhub, Partition: 1 is opening.
[2026-01-20T16:14:01,795][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 1: Opening EH client
[2026-01-20T16:14:01,795][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Watchdog is OFF
[2026-01-20T16:14:01,795][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_fcd6ce_1768954441795], hostName[logstash-input-eventhubs.servicebus.windows.net], info[starting reactor instance.]
[2026-01-20T16:14:01,795][INFO ][com.microsoft.azure.eventhubs.impl.ReactorHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] name[MF_fcd6ce_1768954441795] reactor.onReactorInit
[2026-01-20T16:14:01,795][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionInit hostname[logstash-input-eventhubs.servicebus.windows.net], connectionId[MF_fcd6ce_1768954441795]
[2026-01-20T16:14:01,796][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionLocalOpen hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_fcd6ce_1768954441795], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:01,796][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionBound hostname[logstash-input-eventhubs.servicebus.windows.net], connectionId[MF_fcd6ce_1768954441795]
[2026-01-20T16:14:02,206][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionRemoteOpen hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_fcd6ce_1768954441795], remoteContainer[24270e1f29a54ea9bc24e04b3847d34d_G34]
[2026-01-20T16:14:02,375][INFO ][com.microsoft.azure.eventprocessorhost.PartitionContext][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 1: Retrieved starting offset 12884902176//511
[2026-01-20T16:14:02,376][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 1: Opening EH receiver with epoch 6 at location offset[12884902176], sequenceNumber[null], enqueuedTime[null], inclusiveFlag[false]
[2026-01-20T16:14:02,383][INFO ][com.microsoft.azure.eventhubs.impl.MessageReceiver][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] clientId[PR_404a0a_1768954442379_MF_fcd6ce_1768954441795-InternalReceiver], path[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/1], operationTimeout[PT1M], creating a receive link
[2026-01-20T16:14:02,386][INFO ][com.microsoft.azure.eventhubs.impl.FaultTolerantObject][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] FaultTolerantObject[FTO_61fbd7_1768954442385] client[MF_fcd6ce_1768954441795] session[cbs-session] decided to create cNIO[F] innerObject[null] iOstate[--]
[2026-01-20T16:14:02,386][INFO ][com.microsoft.azure.eventhubs.impl.RequestResponseOpener][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] clientId[MF_fcd6ce_1768954441795] rro[RRO_e30358_1768954442385] opening inner channel
[2026-01-20T16:14:02,386][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_fcd6ce_1768954441795], hostName[logstash-input-eventhubs.servicebus.windows.net], getting a session.
[2026-01-20T16:14:02,387][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionLocalOpen connectionId[MF_fcd6ce_1768954441795], entityName[cbs-session], condition[Error{condition=null, description='null', info=null}]
[2026-01-20T16:14:02,387][INFO ][com.microsoft.azure.eventhubs.impl.SendLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen senderName[cbs], linkName[cbs:sender], localTarget[Target{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}]
[2026-01-20T16:14:02,387][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen receiverName[cbs], linkName[cbs:receiver], localSource[Source{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:02,467][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionRemoteOpen connectionId[MF_fcd6ce_1768954441795], entityName[cbs-session], sessionIncCapacity[0], sessionOutgoingWindow[2147483647]
[2026-01-20T16:14:02,468][INFO ][com.microsoft.azure.eventhubs.impl.SendLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen senderName[cbs], linkName[cbs:sender], remoteTarget[Target{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}]
[2026-01-20T16:14:02,468][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen receiverName[cbs], linkName[cbs:receiver], remoteSource[Source{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:02,468][INFO ][com.microsoft.azure.eventhubs.impl.FaultTolerantObject][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] FaultTolerantObject[FTO_61fbd7_1768954442385] client[MF_fcd6ce_1768954441795] session[cbs-session] inner object rrc[RRC_7c7eac_1768954442386] creation complete
[2026-01-20T16:14:02,469][INFO ][com.microsoft.azure.eventhubs.impl.RequestResponseOpener][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] requestResponseChannel.onOpen complete clientId[MF_fcd6ce_1768954441795], session[cbs-session], link[cbs], endpoint[$cbs], rrc[RRC_7c7eac_1768954442386]
[2026-01-20T16:14:02,574][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_fcd6ce_1768954441795], hostName[logstash-input-eventhubs.servicebus.windows.net], getting a session.
[2026-01-20T16:14:02,575][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionLocalOpen connectionId[MF_fcd6ce_1768954441795], entityName[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/1], condition[Error{condition=null, description='null', info=null}]
[2026-01-20T16:14:02,655][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionRemoteOpen connectionId[MF_fcd6ce_1768954441795], entityName[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/1], sessionIncCapacity[0], sessionOutgoingWindow[2147483647]
[2026-01-20T16:14:02,656][INFO ][com.microsoft.azure.eventhubs.impl.PartitionReceiverImpl][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] receiverPath[RECEIVER IS NULL], action[createReceiveLink], offset[12884902176], sequenceNumber[null], enqueuedTime[null], inclusiveFlag[false]
[2026-01-20T16:14:02,658][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen receiverName[PR_404a0a_1768954442379_MF_fcd6ce_1768954441795-InternalReceiver], linkName[LN_e5b0b0_1768954442657_34d_G34], localSource[Source{address='logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/1', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={apache.org:selector-filter:string=UnknownDescribedType{descriptor=apache.org:selector-filter:string, described=amqp.annotation.x-opt-offset > '12884902176'}}, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:02,752][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen receiverName[PR_404a0a_1768954442379_MF_fcd6ce_1768954441795-InternalReceiver], linkName[LN_e5b0b0_1768954442657_34d_G34], remoteSource[Source{address='logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/1', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={apache.org:selector-filter:string=org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType@6efc803}, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:02,752][INFO ][com.microsoft.azure.eventhubs.impl.MessageReceiver][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Watchdog reset timer for new connection on receiver PR_404a0a_1768954442379_MF_fcd6ce_1768954441795-InternalReceiver
[2026-01-20T16:14:02,752][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 1: EH client and receiver creation finished
[2026-01-20T16:14:02,752][INFO ][com.microsoft.azure.eventhubs.impl.MessageReceiver][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onOpenComplete - clientId[PR_404a0a_1768954442379_MF_fcd6ce_1768954441795-InternalReceiver], receiverPath[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/1], linkName[LN_e5b0b0_1768954442657_34d_G34], updated-link-credit[200], sentCredits[200]
{
    "@timestamp" => 2026-01-21T00:14:31.792669Z,
      "@version" => "1",
       "message" => "Hi",
         "event" => {
        "original" => "{ \"message\": \"Hi\"}"
    }
}
[2026-01-20T16:14:32,796][INFO ][com.microsoft.azure.eventprocessorhost.PumpManager][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 0: creating new pump
[2026-01-20T16:14:32,797][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 0: Creating and opening event processor instance
[2026-01-20T16:14:32,803][INFO ][logstash.codecs.json     ][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] ECS compatibility is enabled but `target` option was not specified. This may cause fields to be set at the top-level of the event where they are likely to clash with the Elastic Common Schema. It is recommended to set the `target` option to avoid potential schema conflicts (if your data is ECS compliant or non-conflicting, feel free to ignore this message)
[2026-01-20T16:14:32,804][INFO ][logstash.inputs.azure.processor][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Event Hub: logstash-demo-eventhub, Partition: 0 is opening.
[2026-01-20T16:14:32,804][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 0: Opening EH client
[2026-01-20T16:14:32,804][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Watchdog is OFF
[2026-01-20T16:14:32,804][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_e436e8_1768954472804], hostName[logstash-input-eventhubs.servicebus.windows.net], info[starting reactor instance.]
[2026-01-20T16:14:32,805][INFO ][com.microsoft.azure.eventhubs.impl.ReactorHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] name[MF_e436e8_1768954472804] reactor.onReactorInit
[2026-01-20T16:14:32,805][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionInit hostname[logstash-input-eventhubs.servicebus.windows.net], connectionId[MF_e436e8_1768954472804]
[2026-01-20T16:14:32,805][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionLocalOpen hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_e436e8_1768954472804], errorCondition[null], errorDescription[null]
[2026-01-20T16:14:32,806][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionBound hostname[logstash-input-eventhubs.servicebus.windows.net], connectionId[MF_e436e8_1768954472804]
[2026-01-20T16:14:33,230][INFO ][com.microsoft.azure.eventhubs.impl.ConnectionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onConnectionRemoteOpen hostname[logstash-input-eventhubs.servicebus.windows.net:5671], connectionId[MF_e436e8_1768954472804], remoteContainer[72fdce1c5f2b4576a54d5fc3134fa1ce_G1]
[2026-01-20T16:14:33,394][INFO ][com.microsoft.azure.eventprocessorhost.PartitionContext][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 0: Retrieved starting offset 42949673456//524
[2026-01-20T16:14:33,394][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 0: Opening EH receiver with epoch 5 at location offset[42949673456], sequenceNumber[null], enqueuedTime[null], inclusiveFlag[false]
[2026-01-20T16:14:33,394][INFO ][com.microsoft.azure.eventhubs.impl.MessageReceiver][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] clientId[PR_529979_1768954473394_MF_e436e8_1768954472804-InternalReceiver], path[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/0], operationTimeout[PT1M], creating a receive link
[2026-01-20T16:14:33,395][INFO ][com.microsoft.azure.eventhubs.impl.FaultTolerantObject][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] FaultTolerantObject[FTO_0ae0a7_1768954473395] client[MF_e436e8_1768954472804] session[cbs-session] decided to create cNIO[F] innerObject[null] iOstate[--]
[2026-01-20T16:14:33,395][INFO ][com.microsoft.azure.eventhubs.impl.RequestResponseOpener][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] clientId[MF_e436e8_1768954472804] rro[RRO_82d9a3_1768954473395] opening inner channel
[2026-01-20T16:14:33,395][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_e436e8_1768954472804], hostName[logstash-input-eventhubs.servicebus.windows.net], getting a session.
[2026-01-20T16:14:33,396][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionLocalOpen connectionId[MF_e436e8_1768954472804], entityName[cbs-session], condition[Error{condition=null, description='null', info=null}]
[2026-01-20T16:14:33,396][INFO ][com.microsoft.azure.eventhubs.impl.SendLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen senderName[cbs], linkName[cbs:sender], localTarget[Target{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}]
[2026-01-20T16:14:33,397][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen receiverName[cbs], linkName[cbs:receiver], localSource[Source{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:33,513][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionRemoteOpen connectionId[MF_e436e8_1768954472804], entityName[cbs-session], sessionIncCapacity[0], sessionOutgoingWindow[2147483647]
[2026-01-20T16:14:33,513][INFO ][com.microsoft.azure.eventhubs.impl.SendLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen senderName[cbs], linkName[cbs:sender], remoteTarget[Target{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}]
[2026-01-20T16:14:33,513][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen receiverName[cbs], linkName[cbs:receiver], remoteSource[Source{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:33,515][INFO ][com.microsoft.azure.eventhubs.impl.FaultTolerantObject][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] FaultTolerantObject[FTO_0ae0a7_1768954473395] client[MF_e436e8_1768954472804] session[cbs-session] inner object rrc[RRC_20849e_1768954473396] creation complete
[2026-01-20T16:14:33,515][INFO ][com.microsoft.azure.eventhubs.impl.RequestResponseOpener][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] requestResponseChannel.onOpen complete clientId[MF_e436e8_1768954472804], session[cbs-session], link[cbs], endpoint[$cbs], rrc[RRC_20849e_1768954473396]
[2026-01-20T16:14:33,595][INFO ][com.microsoft.azure.eventhubs.impl.MessagingFactory][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] messagingFactory[MF_e436e8_1768954472804], hostName[logstash-input-eventhubs.servicebus.windows.net], getting a session.
[2026-01-20T16:14:33,595][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionLocalOpen connectionId[MF_e436e8_1768954472804], entityName[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/0], condition[Error{condition=null, description='null', info=null}]
[2026-01-20T16:14:33,674][INFO ][com.microsoft.azure.eventhubs.impl.SessionHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onSessionRemoteOpen connectionId[MF_e436e8_1768954472804], entityName[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/0], sessionIncCapacity[0], sessionOutgoingWindow[2147483647]
[2026-01-20T16:14:33,674][INFO ][com.microsoft.azure.eventhubs.impl.PartitionReceiverImpl][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] receiverPath[RECEIVER IS NULL], action[createReceiveLink], offset[42949673456], sequenceNumber[null], enqueuedTime[null], inclusiveFlag[false]
[2026-01-20T16:14:33,675][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkLocalOpen receiverName[PR_529979_1768954473394_MF_e436e8_1768954472804-InternalReceiver], linkName[LN_95b5ec_1768954473675_a1ce_G1], localSource[Source{address='logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/0', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={apache.org:selector-filter:string=UnknownDescribedType{descriptor=apache.org:selector-filter:string, described=amqp.annotation.x-opt-offset > '42949673456'}}, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:33,762][INFO ][com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onLinkRemoteOpen receiverName[PR_529979_1768954473394_MF_e436e8_1768954472804-InternalReceiver], linkName[LN_95b5ec_1768954473675_a1ce_G1], remoteSource[Source{address='logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/0', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={apache.org:selector-filter:string=org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType@11873e59}, defaultOutcome=null, outcomes=null, capabilities=null}]
[2026-01-20T16:14:33,762][INFO ][com.microsoft.azure.eventhubs.impl.MessageReceiver][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] Watchdog reset timer for new connection on receiver PR_529979_1768954473394_MF_e436e8_1768954472804-InternalReceiver
[2026-01-20T16:14:33,762][INFO ][com.microsoft.azure.eventprocessorhost.PartitionPump][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] host logstash-c564ebd3-dd33-48f7-aded-d6c906e46506: 0: EH client and receiver creation finished
[2026-01-20T16:14:33,762][INFO ][com.microsoft.azure.eventhubs.impl.MessageReceiver][main][46f3a617d8af9b581050200d19a804c1a39baf97385af0c98fd8bbf74d9ccac4] onOpenComplete - clientId[PR_529979_1768954473394_MF_e436e8_1768954472804-InternalReceiver], receiverPath[logstash-demo-eventhub/ConsumerGroups/$Default/Partitions/0], linkName[LN_95b5ec_1768954473675_a1ce_G1], updated-link-credit[200], sentCredits[200]
{
    "@timestamp" => 2026-01-21T00:14:38.572156Z,
      "@version" => "1",
       "message" => "Hi",
         "event" => {
        "original" => "{ \"message\": \"Hi\"}"
    }
}

donoghuc · 2025-12-22T22:41:16Z

I'm not sure I understand... adal4j is a transitive dep of azure-client-authentication, if we keep azure-client-authentication i think we also have to keep adal4j.

donoghuc · 2025-12-23T00:00:52Z

Looks like these were introduced with 6589acd We can see that they are included as runtime dependencies: https://github.com/Azure/autorest-clientruntime-for-java/blob/master/azure-client-authentication/pom.xml and https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/eventhubs/microsoft-azure-eventhubs/pom.xml

While it does not look like the plugin uses any classes directly, it seems risky removing explicitly declare dependencies (IE how can we be sure those classes are not attempted to be loaded in code paths outside the plugin).

CHANGELOG.md

mashhurs · 2026-01-12T19:38:49Z

We have observed a bug with packaging. Now, as long as we keep the com.microsoft.azure:azure-eventhubs:3.3.0, removing adal4j doesn't make sense.
This will be re-addressed after big fix, #110

CHANGELOG.md

build.gradle

lib/logstash-input-azure_event_hubs.rb

…h packages) and test with Azure cloud env.

donoghuc · 2026-01-21T00:31:22Z

lib/logstash-input-azure_event_hubs.rb

 require_jar('com.microsoft.azure', 'qpid-proton-j-extensions', '1.2.4')
-require_jar('com.microsoft.azure', 'azure-eventhubs-eph', '3.3.0')
 require_jar('com.microsoft.azure', 'azure-storage', '8.6.6')
+require_jar('com.microsoft.azure', 'azure-client-authentication', '1.7.3')


Oh, oops I should have checked these in in my other PR. Thanks

donoghuc

I'm good if CI is!

mashhurs linked an issue Dec 10, 2025 that may be closed by this pull request

Replace adal4j with msal4j #106

Closed

mashhurs requested a review from andsel December 10, 2025 18:45

donoghuc reviewed Dec 23, 2025

View reviewed changes

CHANGELOG.md Outdated Show resolved Hide resolved

mashhurs commented Dec 23, 2025

View reviewed changes

CHANGELOG.md Outdated Show resolved Hide resolved

mashhurs closed this Jan 12, 2026

mashhurs reopened this Jan 20, 2026

mashhurs commented Jan 20, 2026

View reviewed changes

CHANGELOG.md Outdated Show resolved Hide resolved

mashhurs commented Jan 20, 2026

View reviewed changes

build.gradle Outdated Show resolved Hide resolved

lib/logstash-input-azure_event_hubs.rb Outdated Show resolved Hide resolved

mashhurs and others added 4 commits January 20, 2026 16:05

Remove unused adal4j

9fc9e27

Remove azure-client-authentication dependency as well.

a33bda7

Update CHANGELOG.md

919cacf

Rebase with upstream, latest gradle build (list jar-dependencies fres…

cc6070a

…h packages) and test with Azure cloud env.

mashhurs force-pushed the remove-unused-adal4j branch from 1d488c3 to cc6070a Compare January 21, 2026 00:08

Exclude adal4j group consumption.

3f095e5

mashhurs changed the title ~~Remove unused adal4j~~ Jan 21, 2026

donoghuc reviewed Jan 21, 2026

View reviewed changes

donoghuc approved these changes Jan 21, 2026

View reviewed changes

mashhurs merged commit 7fef6a2 into main Jan 21, 2026
4 checks passed

mashhurs deleted the remove-unused-adal4j branch January 21, 2026 01:09

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Remove unused adal4j, refresh consuming dependencies#107

Remove unused adal4j, refresh consuming dependencies#107
mashhurs merged 5 commits intomainfrom
remove-unused-adal4j

mashhurs commented Dec 10, 2025 •

edited

Loading

donoghuc commented Dec 22, 2025

donoghuc commented Dec 23, 2025

Uh oh!

Uh oh!

mashhurs commented Jan 12, 2026

Uh oh!

Uh oh!

Uh oh!

donoghuc Jan 21, 2026

donoghuc left a comment

Uh oh!

Labels

2 participants

Conversation

mashhurs commented Dec 10, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Description

Testing

donoghuc commented Dec 22, 2025

donoghuc commented Dec 23, 2025

Uh oh!

Uh oh!

mashhurs commented Jan 12, 2026

Uh oh!

Uh oh!

Uh oh!

donoghuc Jan 21, 2026

Choose a reason for hiding this comment

donoghuc left a comment

Choose a reason for hiding this comment

Uh oh!

Labels

2 participants

mashhurs commented Dec 10, 2025 •

edited

Loading