feat(migrations): Add migration for inputs.kafka_consumer_legacy

migrations/all/inputs_kafka_consumer_legacy.go

@@ -0,0 +1,5 @@
+//go:build !custom || (migrations && (inputs || inputs.kafka_consumer_legacy))
+
+package all
+
+import _ "github.com/influxdata/telegraf/migrations/inputs_kafka_consumer_legacy" // register migration

migrations/inputs_kafka_consumer_legacy/migration.go

@@ -0,0 +1,21 @@
+package inputs_kafka_consumer_legacy
+
+import (
+	"github.com/influxdata/toml/ast"
+
+	"github.com/influxdata/telegraf/migrations"
+)
+
+const msg = `
+    This plugin cannot be migrated automatically and requires manual intervention!
+`
+
+// Migration function
+func migrate(_ *ast.Table) ([]byte, string, error) {
+	return nil, msg, nil
+}
+
+// Register the migration function for the plugin type
+func init() {
+	migrations.AddPluginMigration("inputs.kafka_consumer_legacy", migrate)
+}

migrations/inputs_kafka_consumer_legacy/migration_test.go

@@ -0,0 +1,29 @@
+package inputs_kafka_consumer_legacy_test
+
+import (
+	"strings"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+
+	"github.com/influxdata/telegraf/config"
+	_ "github.com/influxdata/telegraf/migrations/inputs_kafka_consumer_legacy" // register migration
+)
+
+func TestNoMigration(t *testing.T) {
+	input := []byte(`
+[[inputs.kafka_consumer_legacy]]
+  topics = ["telegraf"]
+  zookeeper_peers = ["localhost:2181"]
+  zookeeper_chroot = ""
+  consumer_group = "telegraf_metrics_consumers"
+  offset = "oldest"
+  data_format = "influx"
+  max_message_len = 65536
+`)
+
+	output, n, err := config.ApplyMigrations(input)
+	require.NoError(t, err)
+	require.Empty(t, strings.TrimSpace(string(output)))
+	require.Equal(t, uint64(1), n)
+}