Skip to content

Commit

Permalink
Use custom yaml with kafka 3.8.0 for AMQ streams operator tests
Browse files Browse the repository at this point in the history
AMQ streams operator 2.8 supports Kafka 3.8.0 or less while default Kafka version from FW is 3.9.0
  • Loading branch information
gtroitsk authored and michalvavrik committed Jan 17, 2025
1 parent d365fdd commit ee99989
Show file tree
Hide file tree
Showing 2 changed files with 40 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,9 @@
@OpenShiftScenario
public class OperatorOpenShiftAmqStreamsKafkaStreamIT extends BaseKafkaStreamTest {

// TODO: use default KafkaInstance constructor when amq streams operator will support kafka 3.9.0+
@Operator(name = "amq-streams", source = "redhat-operators")
static KafkaInstance kafka = new KafkaInstance();
static KafkaInstance kafka = new KafkaInstance("kafka-instance", "/amq-streams-operator-kafka-instance.yaml");

@QuarkusApplication
static RestService app = new RestService()
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: kafka-instance
spec:
kafka:
version: 3.8.0
replicas: 1
listeners:
- name: plain
port: 9092
type: internal
tls: false
- name: tls
port: 9093
type: internal
tls: true
config:
offsets.topic.replication.factor: 1
transaction.state.log.replication.factor: 1
transaction.state.log.min.isr: 1
log.message.format.version: "3.8-IV0"
storage:
type: jbod
volumes:
- id: 0
type: persistent-claim
size: 100Mi
deleteClaim: true
zookeeper:
replicas: 1
storage:
type: persistent-claim
size: 100Mi
deleteClaim: true
entityOperator:
topicOperator: {}
userOperator: {}

0 comments on commit ee99989

Please sign in to comment.