-
Notifications
You must be signed in to change notification settings - Fork 32
Description
Logstash information:
Please include the following information:
- Logstash version (e.g.
bin/logstash --version) - Logstash installation source (e.g. built from source, with a package manager: DEB/RPM, expanded from tar or zip archive, docker)
- How is Logstash being run (e.g. as a service/service manager: systemd, upstart, etc. Via command line, docker/kubernetes)
- How was the Logstash Plugin installed
JVM (e.g. java -version):
If the affected version of Logstash is 7.9 (or earlier), or if it is NOT using the bundled JDK or using the 'no-jdk' version in 7.10 (or higher), please provide the following information:
- JVM version (
java -version) - JVM installation source (e.g. from the Operating System's package manager, from source, etc).
- Value of the
JAVA_HOMEenvironment variable if set.
OS version (uname -a if on a Unix-like system):
Description of the problem including expected versus actual behavior:
When using config_mode => "advanced" and setting multiple event hub settings in the event_hubs => [] param, the plugin doesn't use individual param such as initial_position of the each event_hubs entry. Instead it uses a global initial_position.
It looks like here is the bug that should use case event_hub['initial_position'] instead of case @initial_position : https://github.com/logstash-plugins/logstash-input-azure_event_hubs/blob/main/lib/logstash/inputs/azure_event_hubs.rb#L425
Steps to reproduce:
Please include a minimal but complete recreation of the problem,
including (e.g.) pipeline definition(s), settings, locale, etc. The easier
you make for us to reproduce it, the more likely that somebody will take the
time to look at it.
Provide logs (if relevant):