Fix sink-record to get topic name
@@ -37,6 +37,11 @@ public class SinkRecord<T> implements Record<T> {
return sourceRecord;
}
+ @Override
+ public Optional<String> getTopicName() {
+ return sourceRecord.getTopicName();
+ }
+
@Override
public Optional<String> getKey() {
return sourceRecord.getKey();
