This is an automated email from the ASF dual-hosted git repository.
fjtiradosarti pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-kie-kogito-runtimes.git
The following commit(s) were added to refs/heads/main by this push:
new fc9ae664a3 [incubator-kie-issues-1682] Test cases in kogito repos GHA
fail with … (#3812)
fc9ae664a3 is described below
commit fc9ae664a3e83ad1ca74bdc5f102bb4e5efb03b6
Author: Toshiya Kobayashi <[email protected]>
AuthorDate: Fri Dec 13 01:09:10 2024 +0900
[incubator-kie-issues-1682] Test cases in kogito repos GHA fail with …
(#3812)
* [incubator-kie-issues-1682] Test cases in kogito repos GHA fail with
"pull access denied for vectorized/redpanda"
* Fix advertise-kafka-addr in script command
---------
Co-authored-by: gmunozfe <[email protected]>
---
kogito-build/kogito-build-no-bom-parent/pom.xml | 2 +-
.../java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java | 7 +------
2 files changed, 2 insertions(+), 7 deletions(-)
diff --git a/kogito-build/kogito-build-no-bom-parent/pom.xml
b/kogito-build/kogito-build-no-bom-parent/pom.xml
index afe76bd494..2795ef00b8 100644
--- a/kogito-build/kogito-build-no-bom-parent/pom.xml
+++ b/kogito-build/kogito-build-no-bom-parent/pom.xml
@@ -50,7 +50,7 @@
<!-- container images for testing -->
<container.image.infinispan>infinispan/server:${version.org.infinispan}</container.image.infinispan>
<container.image.keycloak>quay.io/keycloak/keycloak:${version.org.keycloak}</container.image.keycloak>
- <container.image.kafka>vectorized/redpanda:v21.11.8</container.image.kafka>
+
<container.image.kafka>redpandadata/redpanda:v24.3.1</container.image.kafka>
<container.image.wurstmeister.kafka>wurstmeister/kafka:${version.wurstmeister.kafka}</container.image.wurstmeister.kafka>
<container.image.mongodb>library/mongo:${version.org.mongo-image}</container.image.mongodb>
<container.image.redis>redislabs/redisearch:${version.org.redis}</container.image.redis>
diff --git
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
index 6bd3a3dce7..72c594d4f8 100644
---
a/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
+++
b/kogito-test-utils/src/main/java/org/kie/kogito/testcontainers/KogitoKafkaContainer.java
@@ -53,14 +53,13 @@ public class KogitoKafkaContainer extends
KogitoGenericContainer<KogitoKafkaCont
@Override
protected void containerIsStarting(InspectContainerResponse containerInfo,
boolean reused) {
super.containerIsStarting(containerInfo, reused);
- String brokerAdvertisedListener =
brokerAdvertisedListener(containerInfo);
// Start and configure the advertised address
String command = "#!/bin/bash\n";
command += "/usr/bin/rpk redpanda start --check=false --node-id 0
--smp 1 ";
command += "--memory 1G --overprovisioned --reserve-memory 0M ";
command += "--kafka-addr
PLAINTEXT://0.0.0.0:29092,OUTSIDE://0.0.0.0:9092 ";
- command += format("--advertise-kafka-addr %s ", String.join(",",
getBootstrapServers(), brokerAdvertisedListener));
+ command += "--advertise-kafka-addr PLAINTEXT://kafka:29092,OUTSIDE://"
+ getHost() + ":" + getMappedPort(KAFKA_PORT) + " ";
command += "--set redpanda.enable_idempotence=true ";
command += "--set redpanda.enable_transactions=true ";
@@ -73,10 +72,6 @@ public class KogitoKafkaContainer extends
KogitoGenericContainer<KogitoKafkaCont
LOGGER.info("Kafka servers: {}", getBootstrapServers());
}
- protected String brokerAdvertisedListener(InspectContainerResponse
containerInfo) {
- return String.format("PLAINTEXT://%s:29092",
containerInfo.getConfig().getHostName());
- }
-
public String getBootstrapServers() {
return format("OUTSIDE://%s:%d", getHost(), getMappedPort(KAFKA_PORT));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
