schemedkafka inested of schemedkafka

TouK · Nov 17, 2024 · 7a6a235 · 7a6a235
1 parent 10d5732
commit 7a6a235
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/.../nussknacker/engine/schemedkafka/flink/typeinfo/ConsumerRecordTypeSerializerSnapshot.java b/.../nussknacker/engine/schemedkafka/flink/typeinfo/ConsumerRecordTypeSerializerSnapshot.java
@@ -1,11 +1,9 @@
-package pl.touk.nussknacker.engine.schemdkafka.flink.typeinfo;
+package pl.touk.nussknacker.engine.schemedkafka.flink.typeinfo;
 
 import org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
-import pl.touk.nussknacker.engine.schemedkafka.flink.typeinfo.ConsumerRecordSerializer;
-import pl.touk.nussknacker.engine.schemedkafka.flink.typeinfo.ConsumerRecordTypeInfo;
 
 /**
  * A {@link TypeSerializerSnapshot} for the Scala {@link ConsumerRecordTypeInfo}.

diff --git a/...scala/pl/touk/nussknacker/engine/schemedkafka/flink/typeinfo/ConsumerRecordTypeInfo.scala b/...scala/pl/touk/nussknacker/engine/schemedkafka/flink/typeinfo/ConsumerRecordTypeInfo.scala
@@ -7,7 +7,6 @@ import org.apache.flink.core.memory.{DataInputView, DataOutputView}
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.apache.kafka.common.header.internals.{RecordHeader, RecordHeaders}
 import org.apache.kafka.common.record.TimestampType
-import pl.touk.nussknacker.engine.schemdkafka.flink.typeinfo.ConsumerRecordTypeSerializerSnapshot
 
 import java.util.{Objects, Optional}