DBZ-1892 Fix import order.
This commit is contained in:
parent
393758f75b
commit
252beb0785
@ -5,6 +5,8 @@
|
|||||||
*/
|
*/
|
||||||
package io.debezium.connector.cassandra;
|
package io.debezium.connector.cassandra;
|
||||||
|
|
||||||
|
import java.time.Instant;
|
||||||
|
|
||||||
import org.apache.kafka.connect.data.Schema;
|
import org.apache.kafka.connect.data.Schema;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
@ -12,8 +14,6 @@
|
|||||||
import io.debezium.connector.cassandra.exceptions.CassandraConnectorTaskException;
|
import io.debezium.connector.cassandra.exceptions.CassandraConnectorTaskException;
|
||||||
import io.debezium.function.BlockingConsumer;
|
import io.debezium.function.BlockingConsumer;
|
||||||
|
|
||||||
import java.time.Instant;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Responsible for generating ChangeRecord and/or TombstoneRecord for create/update/delete events, as well as EOF events.
|
* Responsible for generating ChangeRecord and/or TombstoneRecord for create/update/delete events, as well as EOF events.
|
||||||
*/
|
*/
|
||||||
|
Loading…
Reference in New Issue
Block a user