THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
while (true) { try { consumer.poll(Duration.ofMillis(50)); } catch (RecordDeserializationException e) { consumer.seek(tpe.partition(), e.offset() + 1); } } |
Compatibility, Deprecation, and Migration Plan
...