This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch fix-kafka-tests
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/fix-kafka-tests by this push:
new a5e7863311d Change kafka cluster
a5e7863311d is described below
commit a5e7863311d8941baea6b427b7ea8571ab53282b
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Tue Oct 7 16:55:26 2025 +0400
Change kafka cluster
---
.github/workflows/beam_PerformanceTests_xlang_KafkaIO_Python.yml | 4 ++--
.github/workflows/beam_StressTests_Java_KafkaIO.yml | 4 ++--
.../strimzi/02-kafka-persistent/base/v0.33.2/kafka-persistent.yaml | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/.github/workflows/beam_PerformanceTests_xlang_KafkaIO_Python.yml
b/.github/workflows/beam_PerformanceTests_xlang_KafkaIO_Python.yml
index e31535286b1..51ce66ed3a7 100644
--- a/.github/workflows/beam_PerformanceTests_xlang_KafkaIO_Python.yml
+++ b/.github/workflows/beam_PerformanceTests_xlang_KafkaIO_Python.yml
@@ -77,7 +77,7 @@ jobs:
- name: Set k8s access
uses: ./.github/actions/setup-k8s-access
with:
- cluster_name: kafka-workflows
+ cluster_name: kafka-tb33gr
k8s_namespace: ${{ matrix.job_name }}-${{ github.run_id }}
cluster_zone: us-central1
- name: Install Kafka
@@ -120,4 +120,4 @@ jobs:
-Prunner=DataflowRunner \
-PloadTest.mainClass=apache_beam.io.external.xlang_kafkaio_perf_test \
-PpythonVersion=3.9 \
- '-PloadTest.args=${{
env.beam_PerfTests_xlang_KafkaIO_Python_test_arguments_1 }}'
\ No newline at end of file
+ '-PloadTest.args=${{
env.beam_PerfTests_xlang_KafkaIO_Python_test_arguments_1 }}'
diff --git a/.github/workflows/beam_StressTests_Java_KafkaIO.yml
b/.github/workflows/beam_StressTests_Java_KafkaIO.yml
index 1230e81324b..242392b480a 100644
--- a/.github/workflows/beam_StressTests_Java_KafkaIO.yml
+++ b/.github/workflows/beam_StressTests_Java_KafkaIO.yml
@@ -74,7 +74,7 @@ jobs:
- name: Set k8s access
uses: ./.github/actions/setup-k8s-access
with:
- cluster_name: kafka-workflows
+ cluster_name: kafka-tb33gr
k8s_namespace: ${{ matrix.job_name }}-${{ github.run_id }}
cluster_zone: us-central1
- name: Install Kafka
@@ -97,4 +97,4 @@ jobs:
- name: run Kafka StressTest Large
uses: ./.github/actions/gradle-command-self-hosted-action
with:
- gradle-command: :it:kafka:KafkaStressTestLarge --info
-DbootstrapServers="${{ steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_0 }}:${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_PORTS_0 }},${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_1 }}:${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_PORTS_1 }},${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_2 }}:${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_PORTS_2 }}"
-DinfluxHost="http://10.128.0.96:8086"; -DinfluxDataba [...]
\ No newline at end of file
+ gradle-command: :it:kafka:KafkaStressTestLarge --info
-DbootstrapServers="${{ steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_0 }}:${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_PORTS_0 }},${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_1 }}:${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_PORTS_1 }},${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_2 }}:${{
steps.set_brokers.outputs.KAFKA_SERVICE_BROKER_PORTS_2 }}"
-DinfluxHost="http://10.128.0.96:8086"; -DinfluxDataba [...]
diff --git
a/.test-infra/kafka/strimzi/02-kafka-persistent/base/v0.33.2/kafka-persistent.yaml
b/.test-infra/kafka/strimzi/02-kafka-persistent/base/v0.33.2/kafka-persistent.yaml
index c1d7a5e2673..7630c3146a9 100644
---
a/.test-infra/kafka/strimzi/02-kafka-persistent/base/v0.33.2/kafka-persistent.yaml
+++
b/.test-infra/kafka/strimzi/02-kafka-persistent/base/v0.33.2/kafka-persistent.yaml
@@ -30,7 +30,7 @@ spec:
requests:
cpu: 8
memory: 64Gi
- version: 3.9.1
+ version: 3.6.0
replicas: 3
config:
offsets.topic.replication.factor: 3
