Skip to content

Commit

Permalink
remove
Browse files Browse the repository at this point in the history
  • Loading branch information
xiaohansong committed Oct 28, 2024
1 parent 4456345 commit 70a31e7
Showing 1 changed file with 0 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,6 @@ class CdcPartitionReader<T : Comparable<T>>(

override fun accept(event: ChangeEvent<String?, String?>) {
numEvents.incrementAndGet()
println("dbz event: $event")
// Get SourceRecord object if possible.
// This object is the preferred way to obtain the current position.
val sourceRecord: SourceRecord? =
Expand Down

0 comments on commit 70a31e7

Please sign in to comment.