DBZ-7946 Add log message during partition open requests
This commit is contained in:
parent
d95e496df0
commit
d292bb8479
@ -122,6 +122,15 @@ public void put(Collection<SinkRecord> records) {
|
||||
LOGGER.trace("[PERF] Mark processed execution time {}", markProcessedStopWatch.durations());
|
||||
}
|
||||
|
||||
@Override
|
||||
public void open(Collection<TopicPartition> partitions) {
|
||||
if (LOGGER.isTraceEnabled()) {
|
||||
for (TopicPartition partition : partitions) {
|
||||
LOGGER.trace("Requested open TopicPartition request for '{}'", partition);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void close(Collection<TopicPartition> partitions) {
|
||||
for (TopicPartition partition : partitions) {
|
||||
|
Loading…
Reference in New Issue
Block a user