Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[BUG] "Expected value to be a 32-bit integer, but it was a java.lang.Long" #292

Open
PauloTemenos opened this issue Oct 15, 2018 · 1 comment
Assignees

Comments

@PauloTemenos
Copy link

The Kafka input plugin looks to have a bug - numeric properties (I tracked around 3 properties before I gave up on «numeric» properties) do not work with, apparently, the number converted to Long then tried to downgrade-cast into Int.

I tried uninstalling the plugin and force-install version 7.1.1, but that version didn't work any better.

These are the 3 properties I tracked for sure to be suffering from this:
fetch_max_wait_ms
heartbeat_interval_ms
max_poll_interval_ms

  • Version: Logstash 6.4.2 downloaded this morning;

  • Operating System: Window 10

  • Error output: "Invalid value 200 for configuration heartbeat.interval.ms: Expected value to be a 32-bit integer, but it was a java.lang.Long"

  • Config File:

  # stdin { }
  kafka
  {
    #auto_commit_interval_ms => 5000
    #auto_offset_reset => earliest
    auto_offset_reset => latest
    enable_auto_commit => true
    
    bootstrap_servers => "localhost:9092"
    check_crcs => false
    client_id => "logstash-42"
    group_id => "logstash2"
    consumer_threads => 1
    decorate_events => true
    #exclude_internal_topics => false
    #fetch_max_bytes => 123
    #fetch_min_bytes => 1
    #fetch_max_wait_ms => 10000 #Expected value to be a 32-bit integer, but it was a java.lang.Long
    #poll_timeout_ms => 10001
    #request_timeout_ms => 25000
    #retry_backoff_ms => 500
    #heartbeat_interval_ms => 200 #Invalid value 200 for configuration heartbeat.interval.ms: Expected value to be a 32-bit integer, but it was a java.lang.Long
    #jaas_path => ""
    #max_partition_fetch_bytes => 4096
    #max_poll_interval_ms => 250 #Expected value to be a 32-bit integer, but it was a java.lang.Long
    #max_poll_records => 100
    #partition_assignment_strategy => "qwerty"
    #security_protocol => "PLAINTEXT"
    #session_timeout_ms => 
    topics => [ "test" ]
    #topics_pattern => ""
    #value_deserializer_class => "org.apache.kafka.common.serialization.StringDeserializer"
  }
}
@AlessandroMenti
Copy link

@PauloTemenos Did you try specifying the numeric properties as strings, like this?

request_timeout_ms => "25000"

This looks suspiciously similar to #199.

@jsvd jsvd self-assigned this Oct 24, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants