(ctx context.Context, brokerID int32)
| 322 | } |
| 323 | |
| 324 | func stopDockerTestBroker(ctx context.Context, brokerID int32) error { |
| 325 | service := fmt.Sprintf("kafka-%d", brokerID) |
| 326 | c := exec.Command("docker", "compose", "stop", service) |
| 327 | c.Stdout = os.Stdout |
| 328 | c.Stderr = os.Stderr |
| 329 | if err := c.Run(); err != nil { |
| 330 | return fmt.Errorf("failed to run docker compose to stop test broker kafka-%d: %w", brokerID, err) |
| 331 | } |
| 332 | return nil |
| 333 | } |
| 334 | |
| 335 | func prepareTestTopics(ctx context.Context, env *testEnvironment) error { |
| 336 | Logger.Println("creating test topics") |
no test coverage detected