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

Attempt to fix kafka cluster test intermittent failure #1827

Open
wants to merge 2 commits into
base: main
Choose a base branch
from

Conversation

rukai
Copy link
Member

@rukai rukai commented Nov 20, 2024

This PR attempts to fix an intermittent failure:

 called `Result::unwrap()` on an `Err` value: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: 


Stack backtrace:
   0: anyhow::error::<impl core::convert::From<E> for anyhow::Error>::from
             at /home/runner/.cargo/registry/src/index.crates.io-6f17d22bba15001f/anyhow-1.0.93/src/backtrace.rs:27:14
   1: <core::result::Result<T,F> as core::ops::try_trait::FromResidual<core::result::Result<core::convert::Infallible,E>>>::from_residual
             at /rustc/f6e511eec7342f59a25f7c0534f1dbea00d01b14/library/core/src/result.rs:1987:27
   2: test_helpers::connection::java::Value::call_async_fallible::{{closure}}
             at /home/runner/work/shotover-proxy/shotover-proxy/test-helpers/src/connection/java.rs:332:24
   3: test_helpers::connection::java::Value::call_async::{{closure}}
             at /home/runner/work/shotover-proxy/shotover-proxy/test-helpers/src/connection/java.rs:326:46
   4: test_helpers::connection::kafka::java::KafkaAdminJava::describe_configs::{{closure}}
             at /home/runner/work/shotover-proxy/shotover-proxy/test-helpers/src/connection/kafka/java.rs:639:14
   5: test_helpers::connection::kafka::KafkaAdmin::describe_configs::{{closure}}
             at /home/runner/work/shotover-proxy/shotover-proxy/test-helpers/src/connection/kafka/mod.rs:602:72
   6: lib::kafka_int_tests::test_cases::admin_setup::{{closure}}
             at ./tests/kafka_int_tests/test_cases.rs:119:10
   7: lib::kafka_int_tests::test_cases::standard_test_suite_base::{{closure}}
             at ./tests/kafka_int_tests/test_cases.rs:1556:37
   8: lib::kafka_int_tests::test_cases::cluster_test_suite::{{closure}}
             at ./tests/kafka_int_tests/test_cases.rs:1941:50
   9: lib::kafka_int_tests::cluster_2_racks_multi_shotover::{{closure}}
             at ./tests/kafka_int_tests/mod.rs:587:57
  10: lib::kafka_int_tests::cluster_2_racks_multi_shotover::case_2_java::{{closure}}
             at ./tests/kafka_int_tests/mod.rs:562:1

The issue only occurs in CI and is fairly rare, I cannot reproduce it locally.

My thinking is that altering the number of partitions and then immediately fetching the config might be causing the config fetch to error out because the altered topic is in some kind of in between state.

Maybe altering a different topic will resolve the issue.
And if it doesnt resolve the issue it at least rules out one possibility.
So lets see how it goes.

Copy link

codspeed-hq bot commented Nov 20, 2024

CodSpeed Performance Report

Merging #1827 will not alter performance

Comparing rukai:intermittent_failure_fix_attempt (97bf6fb) with main (229c9ce)

Summary

✅ 38 untouched benchmarks

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

Successfully merging this pull request may close these issues.

1 participant