We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4d6a9c2 commit fbfbafeCopy full SHA for fbfbafe
src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java
@@ -30,11 +30,7 @@
30
import org.apache.kafka.connect.errors.DataException;
31
import org.apache.kafka.connect.transforms.Transformation;
32
33
-import org.slf4j.Logger;
34
-import org.slf4j.LoggerFactory;
35
-
36
public abstract class ExtractTopic<R extends ConnectRecord<R>> implements Transformation<R> {
37
- private static final Logger log = LoggerFactory.getLogger(ExtractTopic.class);
38
39
private static final List<Schema.Type> SUPPORTED_TYPES_TO_CONVERT_FROM = Arrays.asList(
40
Schema.Type.INT8,
0 commit comments