Skip to content

Commit 5cccd70

Browse files
authored
Some minor fixes around migrator (#3715)
* kafka: deprecate redpanda_migrator_bundle * Revert "kafka/redpandatest: use 127.0.0.1 instead of localhost in HTTP client" This reverts commit 4991164. * redpanda/migrator: skip soak test in CI
1 parent 171432f commit 5cccd70

File tree

5 files changed

+9
-7
lines changed

5 files changed

+9
-7
lines changed

internal/impl/kafka/input_redpanda_migrator_bundle.tmpl.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414

1515
name: redpanda_migrator_bundle
1616
type: input
17-
status: experimental
17+
status: deprecated
1818
categories: [ Services ]
1919
summary: Redpanda Migrator bundle input
2020
description: |

internal/impl/kafka/output_redpanda_migrator_bundle.tmpl.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414

1515
name: redpanda_migrator_bundle
1616
type: output
17-
status: experimental
17+
status: deprecated
1818
categories: [ Services ]
1919
summary: Redpanda Migrator bundle output
2020
description: |

internal/impl/kafka/redpandatest/redpanda.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -103,9 +103,7 @@ func StartRedpanda(t *testing.T, pool *dockertest.Pool, exposeBroker, autocreate
103103
ctx, done := context.WithTimeout(t.Context(), 3*time.Second)
104104
defer done()
105105

106-
req, err := http.NewRequestWithContext(ctx, http.MethodGet,
107-
fmt.Sprintf("http://127.0.0.1:%s/v1/cluster/health_overview", resource.GetPort("9644/tcp")),
108-
nil)
106+
req, err := http.NewRequestWithContext(ctx, http.MethodGet, fmt.Sprintf("http://localhost:%s/v1/cluster/health_overview", resource.GetPort("9644/tcp")), nil)
109107
if err != nil {
110108
return fmt.Errorf("failed to create request: %s", err)
111109
}

internal/impl/redpanda/migrator/integration_soak_test.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020
"errors"
2121
"flag"
2222
"math/rand"
23+
"os"
2324
"strconv"
2425
"testing"
2526
"text/template"
@@ -57,6 +58,9 @@ var (
5758
// You can run resources/docker/profiling containers to get Metrics.
5859
func TestIntegrationMigratorSoak(t *testing.T) {
5960
integration.CheckSkip(t)
61+
if os.Getenv("CI") != "" {
62+
t.Skip("Skipping soak test in CI")
63+
}
6064

6165
ctx := t.Context()
6266

internal/plugins/info.csv

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -224,8 +224,8 @@ redpanda_common ,output ,redpanda_common ,4.39.0 ,enterp
224224
redpanda_data_transform ,processor ,redpanda_data_transform ,4.31.0 ,certified ,n ,n ,n
225225
redpanda_migrator ,input ,redpanda_migrator ,4.66.0 ,certified ,n ,y ,y
226226
redpanda_migrator ,output ,redpanda_migrator ,4.66.0 ,certified ,n ,y ,y
227-
redpanda_migrator_bundle ,input ,redpanda_migrator_bundle ,4.37.0 ,certified ,n ,y ,y
228-
redpanda_migrator_bundle ,output ,redpanda_migrator_bundle ,4.37.0 ,certified ,n ,y ,y
227+
redpanda_migrator_bundle ,input ,redpanda_migrator_bundle ,4.37.0 ,certified ,y ,y ,y
228+
redpanda_migrator_bundle ,output ,redpanda_migrator_bundle ,4.37.0 ,certified ,y ,y ,y
229229
reject ,output ,reject ,0.0.0 ,certified ,n ,y ,y
230230
reject_errored ,output ,reject_errored ,0.0.0 ,certified ,n ,y ,y
231231
resource ,input ,resource ,0.0.0 ,certified ,n ,y ,y

0 commit comments

Comments
 (0)