Expect two topics in response for order service

cloudhut · Mar 28, 2021 · 8fb233c · 8fb233c
1 parent 47be3f8
commit 8fb233c
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/pkg/shop/order_service.go b/pkg/shop/order_service.go
@@ -267,14 +267,19 @@ func (svc *OrderService) createKafkaTopic(ctx context.Context) error {
 	}
 
 	// Check for inner kafka errors
-	if len(res.Topics) != 1 {
-		return fmt.Errorf("unexpected topic response count from create topics request. Expected count '1', actual returned count: '%v'", len(res.Topics))
+	if len(res.Topics) != 2 {
+		return fmt.Errorf("unexpected topic response count from create topics request. Expected count '2', actual returned count: '%v'", len(res.Topics))
 	}
 
 	err = kerr.ErrorForCode(res.Topics[0].ErrorCode)
 	if err != nil {
 		return fmt.Errorf("create topics request failed. Inner kafka error: %w", err)
 	}
 
+	err = kerr.ErrorForCode(res.Topics[1].ErrorCode)
+	if err != nil {
+		return fmt.Errorf("create topics request failed. Inner kafka error: %w", err)
+	}
+
 	return nil
 }