test

kiegroup · Mar 26, 2021 · 704ed24 · 704ed24
1 parent e515cd2
commit 704ed24
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/pkg/controller/kieapp/defaults/defaults_test.go b/pkg/controller/kieapp/defaults/defaults_test.go
@@ -5801,12 +5801,12 @@ func TestRhdmEnvironmentWithKafkaExtDefault(t *testing.T) {
 	kafkaStatus := cr.Status.Applied.Objects.Servers[0].Kafka
 	assert.NotNil(t, kafkaStatus)
 	assert.Empty(t, kafkaStatus.ClientID)
-	assert.Nil(t, kafkaStatus.AutocreateTopics)
+	assert.Equal(t, kafkaStatus.AutocreateTopics, Pbool(true))
 	assert.Nil(t, kafkaStatus.Topics)
-	assert.Empty(t, kafkaStatus.BootstrapServers)
-	assert.Empty(t, kafkaStatus.GroupID)
-	assert.Nil(t, kafkaStatus.Acks)
-	assert.Nil(t, kafkaStatus.MaxBlockMs)
+	assert.Equal(t, kafkaStatus.BootstrapServers, "localhost:9092")
+	assert.Equal(t, kafkaStatus.GroupID, "jbpm-consumer")
+	assert.Equal(t, kafkaStatus.Acks, Pint(1))
+	assert.Equal(t, kafkaStatus.MaxBlockMs, Pint32(2000))
 
 	assert.Equal(t, cr.Spec.Objects.Servers[1].Name, "Server-1")
 	kafkaSpecOne := cr.Spec.Objects.Servers[1].Kafka