diff options
author | Sarah Brofeldt <sarah@qtr.dk> | 2022-10-26 10:41:53 +0200 |
---|---|---|
committer | Sarah Brofeldt <sarah@qtr.dk> | 2022-10-26 15:41:40 +0200 |
commit | af484ef1c4167812bad756132e2b00ad54ae505b (patch) | |
tree | 473c0145f1e1ec6225aa4aa5c7e1a92154f15e12 /nixos/tests/kafka.nix | |
parent | 425e707bb2112d82a96db579f4301aa28e0fc2e4 (diff) |
nixos/tests/kafka: Fix tests
Requires new flags that works across all versions Drops unused 0.9 compat
Diffstat (limited to 'nixos/tests/kafka.nix')
-rw-r--r-- | nixos/tests/kafka.nix | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/nixos/tests/kafka.nix b/nixos/tests/kafka.nix index c0488a0e93a38..79af02710c32b 100644 --- a/nixos/tests/kafka.nix +++ b/nixos/tests/kafka.nix @@ -50,7 +50,7 @@ let kafka.wait_until_succeeds( "${kafkaPackage}/bin/kafka-topics.sh --create " - + "--zookeeper zookeeper1:2181 --partitions 1 " + + "--bootstrap-server localhost:9092 --partitions 1 " + "--replication-factor 1 --topic testtopic" ) kafka.succeed( @@ -58,19 +58,12 @@ let + "${kafkaPackage}/bin/kafka-console-producer.sh " + "--broker-list localhost:9092 --topic testtopic" ) - '' + (if name == "kafka_0_9" then '' - assert "test 1" in kafka.succeed( - "${kafkaPackage}/bin/kafka-console-consumer.sh " - + "--zookeeper zookeeper1:2181 --topic testtopic " - + "--from-beginning --max-messages 1" - ) - '' else '' assert "test 1" in kafka.succeed( "${kafkaPackage}/bin/kafka-console-consumer.sh " + "--bootstrap-server localhost:9092 --topic testtopic " + "--from-beginning --max-messages 1" ) - ''); + ''; }) { inherit system; }); in with pkgs; { |