This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push:
new dd95fc47 [FLINK-30600] Merge flink-table-store-kafka to
flink-table-store-connector
dd95fc47 is described below
commit dd95fc47da7dad818c13bb178a7671db326088d9
Author: Jingsong Lee <[email protected]>
AuthorDate: Mon Jan 9 13:49:55 2023 +0800
[FLINK-30600] Merge flink-table-store-kafka to flink-table-store-connector
This closes #469
---
flink-table-store-connector/pom.xml | 27 ++--
.../store/kafka/KafkaLogDeserializationSchema.java | 0
.../flink/table/store/kafka/KafkaLogOptions.java | 0
.../store/kafka/KafkaLogSerializationSchema.java | 0
.../table/store/kafka/KafkaLogSinkProvider.java | 0
.../table/store/kafka/KafkaLogSourceProvider.java | 0
.../table/store/kafka/KafkaLogStoreFactory.java | 5 +-
.../flink/table/store/kafka/KafkaSinkFunction.java | 0
.../flink/table/store/log/LogSinkProvider.java | 0
.../flink/table/store/log/LogSourceProvider.java | 0
.../table/store/log/LogStoreTableFactory.java | 0
.../flink/table/store/log/LogWriteCallback.java | 0
.../table/store/table/sink/LogSinkFunction.java | 0
.../org.apache.flink.table.factories.Factory | 1 +
.../flink/table/store/kafka/KafkaLogITCase.java | 0
.../store/kafka/KafkaLogSerializationTest.java | 0
.../flink/table/store/kafka/KafkaLogTestUtils.java | 0
.../table/store/kafka/KafkaTableTestBase.java | 0
flink-table-store-dist/pom.xml | 7 -
flink-table-store-docs/pom.xml | 7 -
.../configuration/ConfigOptionsDocGenerator.java | 2 +-
flink-table-store-kafka/pom.xml | 175 ---------------------
.../org.apache.flink.table.factories.Factory | 16 --
.../src/test/resources/log4j2-test.properties | 38 -----
pom.xml | 1 -
25 files changed, 14 insertions(+), 265 deletions(-)
diff --git a/flink-table-store-connector/pom.xml
b/flink-table-store-connector/pom.xml
index d80794de..5a8a2c2a 100644
--- a/flink-table-store-connector/pom.xml
+++ b/flink-table-store-connector/pom.xml
@@ -74,6 +74,13 @@ under the License.
<version>6.20.3-ververica-1.0</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>${flink.connector.kafka}</artifactId>
+ <version>${flink.version}</version>
+ <scope>provided</scope>
+ </dependency>
+
<!-- test dependencies -->
<dependency>
@@ -107,21 +114,6 @@ under the License.
<type>test-jar</type>
</dependency>
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-store-kafka</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-store-kafka</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- <type>test-jar</type>
- </dependency>
-
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>${flink.test.utils}</artifactId>
@@ -242,15 +234,16 @@ under the License.
<dependency>
<groupId>org.apache.flink</groupId>
- <artifactId>${flink.connector.kafka}</artifactId>
+ <artifactId>flink-json</artifactId>
<version>${flink.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
- <artifactId>flink-json</artifactId>
+ <artifactId>${flink.connector.kafka}</artifactId>
<version>${flink.version}</version>
+ <type>test-jar</type>
<scope>test</scope>
</dependency>
</dependencies>
diff --git
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogDeserializationSchema.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogDeserializationSchema.java
similarity index 100%
rename from
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogDeserializationSchema.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogDeserializationSchema.java
diff --git
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogOptions.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogOptions.java
similarity index 100%
rename from
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogOptions.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogOptions.java
diff --git
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSerializationSchema.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSerializationSchema.java
similarity index 100%
rename from
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSerializationSchema.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSerializationSchema.java
diff --git
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
similarity index 100%
rename from
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
diff --git
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSourceProvider.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSourceProvider.java
similarity index 100%
rename from
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSourceProvider.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSourceProvider.java
diff --git
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogStoreFactory.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogStoreFactory.java
similarity index 98%
rename from
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogStoreFactory.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogStoreFactory.java
index 6a76e2eb..e6ddbcdd 100644
---
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogStoreFactory.java
+++
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaLogStoreFactory.java
@@ -29,7 +29,6 @@ import org.apache.flink.table.catalog.UniqueConstraint;
import org.apache.flink.table.connector.sink.DynamicTableSink;
import org.apache.flink.table.connector.source.DynamicTableSource;
import org.apache.flink.table.data.RowData;
-import org.apache.flink.table.factories.DynamicTableFactory;
import org.apache.flink.table.factories.FactoryUtil;
import org.apache.flink.table.store.CoreOptions;
import org.apache.flink.table.store.log.LogStoreTableFactory;
@@ -172,7 +171,7 @@ public class KafkaLogStoreFactory implements
LogStoreTableFactory {
@Override
public KafkaLogSourceProvider createSourceProvider(
- DynamicTableFactory.Context context,
+ Context context,
DynamicTableSource.Context sourceContext,
@Nullable int[][] projectFields) {
FactoryUtil.TableFactoryHelper helper = createTableFactoryHelper(this,
context);
@@ -205,7 +204,7 @@ public class KafkaLogStoreFactory implements
LogStoreTableFactory {
@Override
public KafkaLogSinkProvider createSinkProvider(
- DynamicTableFactory.Context context, DynamicTableSink.Context
sinkContext) {
+ Context context, DynamicTableSink.Context sinkContext) {
FactoryUtil.TableFactoryHelper helper = createTableFactoryHelper(this,
context);
ResolvedSchema schema = context.getCatalogTable().getResolvedSchema();
DataType physicalType = schema.toPhysicalRowDataType();
diff --git
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaSinkFunction.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaSinkFunction.java
similarity index 100%
rename from
flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaSinkFunction.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/kafka/KafkaSinkFunction.java
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogSinkProvider.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogSinkProvider.java
similarity index 100%
rename from
flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogSinkProvider.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogSinkProvider.java
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogSourceProvider.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogSourceProvider.java
similarity index 100%
rename from
flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogSourceProvider.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogSourceProvider.java
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogStoreTableFactory.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogStoreTableFactory.java
similarity index 100%
rename from
flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogStoreTableFactory.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogStoreTableFactory.java
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogWriteCallback.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogWriteCallback.java
similarity index 100%
rename from
flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogWriteCallback.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/log/LogWriteCallback.java
diff --git
a/flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/LogSinkFunction.java
b/flink-table-store-connector/src/main/java/org/apache/flink/table/store/table/sink/LogSinkFunction.java
similarity index 100%
rename from
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/LogSinkFunction.java
rename to
flink-table-store-connector/src/main/java/org/apache/flink/table/store/table/sink/LogSinkFunction.java
diff --git
a/flink-table-store-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
b/flink-table-store-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
index daec2168..cc3b8132 100644
---
a/flink-table-store-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
+++
b/flink-table-store-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
@@ -16,3 +16,4 @@
org.apache.flink.table.store.connector.TableStoreManagedFactory
org.apache.flink.table.store.connector.TableStoreConnectorFactory
org.apache.flink.table.store.connector.FlinkCatalogFactory
+org.apache.flink.table.store.kafka.KafkaLogStoreFactory
diff --git
a/flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogITCase.java
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaLogITCase.java
similarity index 100%
rename from
flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogITCase.java
rename to
flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaLogITCase.java
diff --git
a/flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogSerializationTest.java
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaLogSerializationTest.java
similarity index 100%
rename from
flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogSerializationTest.java
rename to
flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaLogSerializationTest.java
diff --git
a/flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogTestUtils.java
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaLogTestUtils.java
similarity index 100%
rename from
flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogTestUtils.java
rename to
flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaLogTestUtils.java
diff --git
a/flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaTableTestBase.java
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaTableTestBase.java
similarity index 100%
rename from
flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaTableTestBase.java
rename to
flink-table-store-connector/src/test/java/org/apache/flink/table/store/kafka/KafkaTableTestBase.java
diff --git a/flink-table-store-dist/pom.xml b/flink-table-store-dist/pom.xml
index ee987aa2..f0db602a 100644
--- a/flink-table-store-dist/pom.xml
+++ b/flink-table-store-dist/pom.xml
@@ -62,12 +62,6 @@ under the License.
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-store-kafka</artifactId>
- <version>${project.version}</version>
- </dependency>
-
<!-- used flink connectors -->
<dependency>
@@ -97,7 +91,6 @@ under the License.
<include>org.apache.flink:flink-table-store-connector</include>
<include>org.apache.flink:flink-table-store-core</include>
<include>org.apache.flink:flink-table-store-format</include>
-
<include>org.apache.flink:flink-table-store-kafka</include>
<include>org.apache.flink:${flink.connector.kafka}</include>
<include>org.apache.kafka:*</include>
</includes>
diff --git a/flink-table-store-docs/pom.xml b/flink-table-store-docs/pom.xml
index 15d39a0a..4bcf8ff3 100644
--- a/flink-table-store-docs/pom.xml
+++ b/flink-table-store-docs/pom.xml
@@ -51,13 +51,6 @@ under the License.
<scope>provided</scope>
</dependency>
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-store-kafka</artifactId>
- <version>${project.version}</version>
- <scope>provided</scope>
- </dependency>
-
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-core</artifactId>
diff --git
a/flink-table-store-docs/src/main/java/org/apache/flink/table/store/docs/configuration/ConfigOptionsDocGenerator.java
b/flink-table-store-docs/src/main/java/org/apache/flink/table/store/docs/configuration/ConfigOptionsDocGenerator.java
index 225515b9..db563a54 100644
---
a/flink-table-store-docs/src/main/java/org/apache/flink/table/store/docs/configuration/ConfigOptionsDocGenerator.java
+++
b/flink-table-store-docs/src/main/java/org/apache/flink/table/store/docs/configuration/ConfigOptionsDocGenerator.java
@@ -75,7 +75,7 @@ public class ConfigOptionsDocGenerator {
new OptionsClassLocation(
"flink-table-store-connector",
"org.apache.flink.table.store.connector"),
new OptionsClassLocation(
- "flink-table-store-kafka",
"org.apache.flink.table.store.kafka")
+ "flink-table-store-connector",
"org.apache.flink.table.store.kafka")
};
static final String DEFAULT_PATH_PREFIX = "src/main/java";
diff --git a/flink-table-store-kafka/pom.xml b/flink-table-store-kafka/pom.xml
deleted file mode 100644
index f12a8405..00000000
--- a/flink-table-store-kafka/pom.xml
+++ /dev/null
@@ -1,175 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0";
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <artifactId>flink-table-store-parent</artifactId>
- <groupId>org.apache.flink</groupId>
- <version>0.4-SNAPSHOT</version>
- </parent>
-
- <artifactId>flink-table-store-kafka</artifactId>
- <name>Flink Table Store : Kafka</name>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-store-core</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <!-- flink dependencies -->
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>${flink.connector.kafka}</artifactId>
- <version>${flink.version}</version>
- <scope>provided</scope>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-common</artifactId>
- <version>${flink.version}</version>
- <scope>provided</scope>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>${flink.table.runtime}</artifactId>
- <version>${flink.version}</version>
- <scope>provided</scope>
- </dependency>
-
- <!-- test dependencies -->
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-table-store-core</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- <type>test-jar</type>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
-
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
- <version>${flink.version}</version>
- <scope>test</scope>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-json</artifactId>
- <version>${flink.version}</version>
- <scope>test</scope>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>${flink.test.utils}</artifactId>
- <version>${flink.version}</version>
- <scope>test</scope>
- <exclusions>
- <exclusion>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- </exclusion>
- </exclusions>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>${flink.connector.kafka}</artifactId>
- <version>${flink.version}</version>
- <type>test-jar</type>
- <scope>test</scope>
- </dependency>
-
- <dependency>
- <!-- include 2.0 server for tests -->
- <groupId>org.apache.kafka</groupId>
- <artifactId>kafka_${scala.binary.version}</artifactId>
- <version>2.8.1</version>
- <exclusions>
- <exclusion>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-api</artifactId>
- </exclusion>
- <exclusion>
- <groupId>com.fasterxml.jackson.core</groupId>
- <artifactId>*</artifactId>
- </exclusion>
- <exclusion>
- <groupId>com.fasterxml.jackson.dataformat</groupId>
- <artifactId>*</artifactId>
- </exclusion>
- <exclusion>
- <groupId>com.fasterxml.jackson.module</groupId>
- <artifactId>*</artifactId>
- </exclusion>
- <exclusion>
- <groupId>com.fasterxml.jackson.datatype</groupId>
- <artifactId>*</artifactId>
- </exclusion>
- </exclusions>
- <scope>test</scope>
- </dependency>
-
- <dependency>
- <groupId>org.testcontainers</groupId>
- <artifactId>kafka</artifactId>
- <version>${testcontainers.version}</version>
- <scope>test</scope>
- <exclusions>
- <exclusion>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- </exclusion>
- </exclusions>
- </dependency>
-
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <version>${junit4.version}</version>
- <scope>test</scope>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-jar-plugin</artifactId>
- <executions>
- <execution>
- <goals>
- <goal>test-jar</goal>
- </goals>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
-</project>
diff --git
a/flink-table-store-kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
b/flink-table-store-kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
deleted file mode 100644
index df0c6b88..00000000
---
a/flink-table-store-kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
+++ /dev/null
@@ -1,16 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-org.apache.flink.table.store.kafka.KafkaLogStoreFactory
diff --git a/flink-table-store-kafka/src/test/resources/log4j2-test.properties
b/flink-table-store-kafka/src/test/resources/log4j2-test.properties
deleted file mode 100644
index 6f324f58..00000000
--- a/flink-table-store-kafka/src/test/resources/log4j2-test.properties
+++ /dev/null
@@ -1,38 +0,0 @@
-################################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-################################################################################
-
-# Set root logger level to OFF to not flood build logs
-# set manually to INFO for debugging purposes
-rootLogger.level = OFF
-rootLogger.appenderRef.test.ref = TestLogger
-
-appender.testlogger.name = TestLogger
-appender.testlogger.type = CONSOLE
-appender.testlogger.target = SYSTEM_ERR
-appender.testlogger.layout.type = PatternLayout
-appender.testlogger.layout.pattern = %-4r [%tid %t] %-5p %c %x - %m%n
-
-logger.kafka.name = kafka
-logger.kafka.level = OFF
-logger.kafka2.name = state.change
-logger.kafka2.level = OFF
-
-logger.zookeeper.name = org.apache.zookeeper
-logger.zookeeper.level = OFF
-logger.I0Itec.name = org.I0Itec
-logger.I0Itec.level = OFF
diff --git a/pom.xml b/pom.xml
index 28a13c1b..25f8ff02 100644
--- a/pom.xml
+++ b/pom.xml
@@ -65,7 +65,6 @@ under the License.
<module>flink-table-store-format</module>
<module>flink-table-store-shade</module>
<module>flink-table-store-hive</module>
- <module>flink-table-store-kafka</module>
<module>flink-table-store-spark</module>
<module>flink-table-store-spark2</module>
</modules>
