open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update kafka docker image (#11938)

This commit is contained in:
Lauri Tulmin 2024-08-01 21:42:07 +03:00 committed by GitHub
parent 9ae38c08d0
commit b0818cb3ed
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
7 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafka/internal/AbstractOpenTelemetryMetricsReporterTest.java
View File

@ -78,7 +78,7 @@ public abstract class AbstractOpenTelemetryMetricsReporterTest {
} }
kafka = kafka =
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10")) new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"))
.withEnv("KAFKA_HEAP_OPTS", "-Xmx256m") .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
.withLogConsumer(new Slf4jLogConsumer(logger)) .withLogConsumer(new Slf4jLogConsumer(logger))
.waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1)) .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))

2
instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafka/internal/KafkaClientBaseTest.java
View File

@ -66,7 +66,7 @@ public abstract class KafkaClientBaseTest {
@BeforeAll @BeforeAll
void setupClass() throws ExecutionException, InterruptedException, TimeoutException { void setupClass() throws ExecutionException, InterruptedException, TimeoutException {
kafka = kafka =
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10")) new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"))
.withEnv("KAFKA_HEAP_OPTS", "-Xmx256m") .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
.withLogConsumer(new Slf4jLogConsumer(logger)) .withLogConsumer(new Slf4jLogConsumer(logger))
.waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1)) .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))

2
instrumentation/kafka/kafka-streams-0.11/javaagent/src/test/groovy/KafkaStreamsBaseTest.groovy
View File

@ -44,7 +44,7 @@ class KafkaStreamsBaseTest extends AgentInstrumentationSpecification {
static CountDownLatch consumerReady = new CountDownLatch(1) static CountDownLatch consumerReady = new CountDownLatch(1)
def setupSpec() { def setupSpec() {
kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10")) kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"))
.withEnv("KAFKA_HEAP_OPTS", "-Xmx256m") .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
.withLogConsumer(new Slf4jLogConsumer(logger)) .withLogConsumer(new Slf4jLogConsumer(logger))
.waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1)) .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))

2
instrumentation/reactor/reactor-kafka-1.0/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/reactor/kafka/v1_0/AbstractReactorKafkaTest.java
View File

@ -69,7 +69,7 @@ public abstract class AbstractReactorKafkaTest {
@BeforeAll @BeforeAll
static void setUpAll() { static void setUpAll() {
kafka = kafka =
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10")) new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"))
.withEnv("KAFKA_HEAP_OPTS", "-Xmx256m") .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
.withLogConsumer(new Slf4jLogConsumer(logger)) .withLogConsumer(new Slf4jLogConsumer(logger))
.waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1)) .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))

2
instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/AbstractSpringKafkaTest.java
View File

@ -46,7 +46,7 @@ public abstract class AbstractSpringKafkaTest {
@BeforeAll @BeforeAll
static void setUpKafka() { static void setUpKafka() {
kafka = kafka =
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10")) new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"))
.withEnv("KAFKA_HEAP_OPTS", "-Xmx256m") .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
.waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1)) .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))
.withStartupTimeout(Duration.ofMinutes(1)); .withStartupTimeout(Duration.ofMinutes(1));

2
instrumentation/vertx/vertx-kafka-client-3.6/testing/src/main/java/io/opentelemetry/javaagent/instrumentation/vertx/kafka/v3_6/AbstractVertxKafkaTest.java
View File

@ -61,7 +61,7 @@ public abstract class AbstractVertxKafkaTest {
@BeforeAll @BeforeAll
static void setUpAll() { static void setUpAll() {
kafka = kafka =
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10")) new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"))
.withEnv("KAFKA_HEAP_OPTS", "-Xmx256m") .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
.withLogConsumer(new Slf4jLogConsumer(logger)) .withLogConsumer(new Slf4jLogConsumer(logger))
.waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1)) .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))

2
smoke-tests-otel-starter/spring-boot-common/src/main/java/io/opentelemetry/spring/smoketest/AbstractJvmKafkaSpringStarterSmokeTest.java
View File

@ -30,7 +30,7 @@ public class AbstractJvmKafkaSpringStarterSmokeTest extends AbstractKafkaSpringS
@BeforeAll @BeforeAll
static void setUpKafka() { static void setUpKafka() {
kafka = kafka =
new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.10")) new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.7.0"))
.withEnv("KAFKA_HEAP_OPTS", "-Xmx256m") .withEnv("KAFKA_HEAP_OPTS", "-Xmx256m")
.waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1)) .waitingFor(Wait.forLogMessage(".*started \\(kafka.server.KafkaServer\\).*", 1))
.withStartupTimeout(Duration.ofMinutes(1)); .withStartupTimeout(Duration.ofMinutes(1));