From 3802a2b3d8e3df2880d013dc1870f21b7bf4a12b Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Fri, 9 Dec 2022 13:37:52 +0800 Subject: [PATCH] Replace ConsumerConfig.GROUP_ID_CONFIG by DistributedConfig.GROUP_ID_CONFIG --- it/src/main/java/org/astraea/it/Services.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/it/src/main/java/org/astraea/it/Services.java b/it/src/main/java/org/astraea/it/Services.java index faf39d4c48..21e198892f 100644 --- a/it/src/main/java/org/astraea/it/Services.java +++ b/it/src/main/java/org/astraea/it/Services.java @@ -33,7 +33,6 @@ import kafka.server.KafkaConfig; import kafka.server.KafkaConfig$; import kafka.server.KafkaServer; -import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.common.network.ListenerName; import org.apache.kafka.common.utils.SystemTime; import org.apache.kafka.connect.cli.ConnectDistributed; @@ -70,7 +69,7 @@ static WorkerCluster workerCluster(BrokerCluster bk, int[] ports) { config.put(DistributedConfig.STATUS_STORAGE_REPLICATION_FACTOR_CONFIG, "1"); // set the brokers info config.put(WorkerConfig.BOOTSTRAP_SERVERS_CONFIG, bk.bootstrapServers()); - config.put(ConsumerConfig.GROUP_ID_CONFIG, "connect"); + config.put(DistributedConfig.GROUP_ID_CONFIG, "connect"); // set the normal converter config.put( ConnectorConfig.KEY_CONVERTER_CLASS_CONFIG,