duplicated block id: 1 size: 6 cleaned lines of code in 2 files: - timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkConnector.java (47:54) - timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceConnector.java (59:66)