pull/1765/head
shedfreewu 2 months ago
parent f3edb76d61
commit 0f1a279de4

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.kafka;
package com.tencent.cloud.plugin.mq.lane.kafka;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
@ -28,7 +28,7 @@ import java.util.Set;
import com.tencent.cloud.common.metadata.MetadataContext;
import com.tencent.cloud.common.metadata.MetadataContextHolder;
import com.tencent.cloud.common.tsf.TsfContextUtils;
import com.tencent.cloud.plugin.lane.tsf.TsfActiveLane;
import com.tencent.cloud.plugin.mq.lane.tsf.TsfActiveLane;
import com.tencent.cloud.polaris.context.PolarisSDKContextManager;
import com.tencent.polaris.api.pojo.ServiceKey;
import com.tencent.polaris.api.utils.StringUtils;

@ -15,10 +15,10 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.kafka;
package com.tencent.cloud.plugin.mq.lane.kafka;
import com.tencent.cloud.common.tsf.ConditionalOnOnlyTsfConsulEnabled;
import com.tencent.cloud.plugin.lane.tsf.TsfActiveLane;
import com.tencent.cloud.plugin.mq.lane.tsf.TsfActiveLane;
import com.tencent.cloud.polaris.context.PolarisSDKContextManager;
import com.tencent.cloud.polaris.discovery.PolarisDiscoveryHandler;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.kafka;
package com.tencent.cloud.plugin.mq.lane.kafka;
import org.springframework.boot.context.properties.ConfigurationProperties;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.tsf;
package com.tencent.cloud.plugin.mq.lane.tsf;
import java.util.HashMap;
import java.util.HashSet;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.tsf;
package com.tencent.cloud.plugin.mq.lane.tsf;
import com.tencent.polaris.api.plugin.registry.AbstractResourceEventListener;
import com.tencent.polaris.api.pojo.RegistryCacheValue;

@ -1,2 +1,2 @@
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.tencent.cloud.plugin.lane.kafka.KafkaLaneAspectConfiguration
com.tencent.cloud.plugin.mq.lane.kafka.KafkaLaneAspectConfiguration

@ -15,13 +15,13 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.kafka;
package com.tencent.cloud.plugin.mq.lane.kafka;
import java.lang.reflect.Field;
import java.util.concurrent.atomic.AtomicBoolean;
import com.tencent.cloud.common.tsf.TsfContextUtils;
import com.tencent.cloud.plugin.lane.tsf.TsfActiveLane;
import com.tencent.cloud.plugin.mq.lane.tsf.TsfActiveLane;
import com.tencent.cloud.polaris.context.PolarisSDKContextManager;
import com.tencent.cloud.polaris.discovery.PolarisDiscoveryHandler;
import org.junit.jupiter.api.AfterEach;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.kafka;
package com.tencent.cloud.plugin.mq.lane.kafka;
import java.lang.reflect.Field;
import java.nio.charset.StandardCharsets;
@ -25,7 +25,7 @@ import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import com.tencent.cloud.common.tsf.TsfContextUtils;
import com.tencent.cloud.plugin.lane.tsf.TsfActiveLane;
import com.tencent.cloud.plugin.mq.lane.tsf.TsfActiveLane;
import com.tencent.cloud.polaris.context.PolarisSDKContextManager;
import com.tencent.polaris.plugins.router.lane.LaneUtils;
import org.apache.kafka.clients.consumer.ConsumerRecord;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.kafka;
package com.tencent.cloud.plugin.mq.lane.kafka;
import org.junit.jupiter.api.Test;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.kafka;
package com.tencent.cloud.plugin.mq.lane.kafka;
import java.lang.reflect.Field;
import java.nio.charset.StandardCharsets;
@ -26,7 +26,7 @@ import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import com.tencent.cloud.common.tsf.TsfContextUtils;
import com.tencent.cloud.plugin.lane.tsf.TsfActiveLane;
import com.tencent.cloud.plugin.mq.lane.tsf.TsfActiveLane;
import com.tencent.cloud.polaris.context.PolarisSDKContextManager;
import com.tencent.polaris.plugins.router.lane.LaneUtils;
import org.apache.kafka.clients.consumer.ConsumerRecord;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.tsf;
package com.tencent.cloud.plugin.mq.lane.tsf;
import java.util.Arrays;
import java.util.Collections;

@ -15,7 +15,7 @@
* specific language governing permissions and limitations under the License.
*/
package com.tencent.cloud.plugin.lane.tsf;
package com.tencent.cloud.plugin.mq.lane.tsf;
import com.tencent.polaris.api.pojo.RegistryCacheValue;
import com.tencent.polaris.api.pojo.ServiceEventKey;
Loading…
Cancel
Save