30 lines
717 B
Go
30 lines
717 B
Go
|
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)
|
||
|
|
}
|