fix integration tests

deviceinsight · Feb 11, 2025 · e7b6bdc · e7b6bdc
1 parent 678a213
commit e7b6bdc
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/cmd/create/create-topic_test.go b/cmd/create/create-topic_test.go
@@ -31,6 +31,7 @@ func TestCreateTopicWithoutFlagsIntegration(t *testing.T) {
 
 	expected := `
 name: %s
+replicationFactor: 1
 partitions:
 - id: 0
   oldestOffset: 0
@@ -62,6 +63,7 @@ func TestCreateTopicWithTwoPartitionsIntegration(t *testing.T) {
 
 	expected := `
 name: %s
+replicationFactor: 1
 partitions:
 - id: 0
   oldestOffset: 0
@@ -99,6 +101,7 @@ func TestCreateTopicWithReplicationFactorIntegration(t *testing.T) {
 
 	expected := `
 name: %s
+replicationFactor: 3
 partitions:
 - id: 0
   oldestOffset: 0
@@ -171,6 +174,7 @@ configs:
 
 	expected := `
 name: %s
+replicationFactor: 1
 partitions:
 - id: 0
   oldestOffset: 0

diff --git a/internal/topic/topic-operation.go b/internal/topic/topic-operation.go
@@ -21,7 +21,7 @@ import (
 
 type Topic struct {
 	Name              string
-	ReplicationFactor int
+	ReplicationFactor int               `json:"replicationFactor" yaml:"replicationFactor"`
 	Partitions        []Partition       `json:",omitempty" yaml:",omitempty"`
 	Configs           []internal.Config `json:",omitempty" yaml:",omitempty"`
 }