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

Kafka Executor - client has run out of available brokers to talk to: EOF #800

Closed
calinDM opened this issue Jun 17, 2024 · 1 comment
Closed
Labels

Comments

@calinDM
Copy link

calinDM commented Jun 17, 2024

Venom 1.2.0 fails to connect redpanda kafka broker with the following message:
step #1-0: Assertion "result.err ShouldBeEmpty" failed. expected 'error instantiate consumer err: kafka: client has run out of available brokers to talk to: EOF' to be empty but it wasn't

Example:
`
testcases:

  • name: Check that message was sent
    steps:
    • type: kafka
      clientType: consumer
      withAvro: true
      markOffset: true
      timeout: 15
      waitFor: 10
      messageLimit: 1
      groupID: venom-consumer
      addrs:
      • "{{.kafkaBrokerTarget}}"
        schemaRegistryAddr: "{{.kafkaSchemaRegistryURL}}"
        topics:
      • {{.kafkaTopicName}}
        assertions:
      • "result.err ShouldBeEmpty"
      • "result.messages.len ShouldEqual 1"
      • "result.messagesjson.messagesjson0.err ShouldBeEmpty"
      • "result.messagesjson.messagesjson0.value ShouldNotBeEmpty"
        `

Workaround:

Set kafkaVersion:"2.0.0" as in

`
testcases:

  • name: Check that message was sent
    steps:
    • type: kafka
      clientType: consumer
      kafkaVersion: "2.0.0"
      withAvro: true
      markOffset: true
      timeout: 15
      waitFor: 10
      messageLimit: 1
      groupID: venom-consumer
      addrs:
      • "{{.kafkaBrokerTarget}}"
        schemaRegistryAddr: "{{.kafkaSchemaRegistryURL}}"
        topics:
      • {{.kafkaTopicName}}
        assertions:
      • "result.err ShouldBeEmpty"
      • "result.messages.len ShouldEqual 1"
      • "result.messagesjson.messagesjson0.err ShouldBeEmpty"
      • "result.messagesjson.messagesjson0.value ShouldNotBeEmpty"
        `
@yesnault
Copy link
Member

yes, kafkaVersion is probably required for you;

" - kafka_version optional, default is 0.10.2.0"

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants