THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Where :
TopicPartition
comes from org.apache.kafka.common package
DeleteRecords
and DeleteRecordsResult
are defined as follow.
...
In the DeleteRecordsResult
, the Long value accessed by values()
and all()
method specifies the low watermark as described in the KIP-107.
...