elastic / beats

:tropical_fish: Beats - Lightweight shippers for Elasticsearch & Logstash
https://www.elastic.co/products/beats
Other
103 stars 4.92k forks source link

How to judge the default version of kafka used by filebeat7.17.9 #35107

Closed fw0037 closed 1 month ago

fw0037 commented 1 year ago

I found such description in file https://github.com/elastic/beats/blob/v7.17.9/libbeat/common/kafka/version.go : // Version is a kafka version type Version string var ( // Sarama expects version strings to be fully expanded, e.g. "1.1.1". // We also allow versions to be specified as a prefix, e.g. "1", // understood as referencing the most recent version starting with "1". // truncatedKafkaVersions stores a lookup of the abbreviations we accept. truncatedKafkaVersions = map[string]sarama.KafkaVersion{ "0.8.2": sarama.V0_8_2_2, "0.8": sarama.V0_8_2_2,

    "0.9.0": sarama.V0_9_0_1,
    "0.9":   sarama.V0_9_0_1,

    "0.10.0": sarama.V0_10_0_1,
    "0.10.1": sarama.V0_10_1_0,
    "0.10.2": sarama.V0_10_2_1,
    "0.10":   sarama.V0_10_2_1,

    "0.11.0": sarama.V0_11_0_2,
    "0.11":   sarama.V0_11_0_2,

    "1.0": sarama.V1_0_0_0,
    "1.1": sarama.V1_1_1_0,
    "1":   sarama.V1_1_1_0,

    "2.0": sarama.V2_0_1_0,
    "2.1": sarama.V2_1_0_0,
    "2.2": sarama.V2_2_0_0,
    "2.3": sarama.V2_3_0_0,
    "2.4": sarama.V2_4_0_0,
    "2.5": sarama.V2_5_0_0,
    "2.6": sarama.V2_6_0_0,
    "2":   sarama.V2_6_0_0,
}

)

Now the question is how to judge which version of Kafka filebeat7.17.9 really corresponds to? kafka version 2.6 , or others?

botelastic[bot] commented 1 year ago

This issue doesn't have a Team:<team> label.

botelastic[bot] commented 7 months ago

Hi! We just realized that we haven't looked into this issue in a while. We're sorry!

We're labeling this issue as Stale to make it hit our filters and make sure we get back to it as soon as possible. In the meantime, it'd be extremely helpful if you could take a look at it as well and confirm its relevance. A simple comment with a nice emoji will be enough :+1. Thank you for your contribution!