In seekPartitions, invoked on RESET with the previously assigned partitions:
The try-catch-block around seek (line 778) catches the wrong exception (IllegalArgumentException, line 811) to capture the event that the seeked partition is not owned by the consumer anymore. The consumer throws an IllegalStateException when a partition is not owned anymore.
ghost
commented
4 years ago
https://github.com/IBMStreams/streamsx.kafka/blob/1fd99925d716cf3a4c782e4f8c5113be2154db76/com.ibm.streamsx.kafka/impl/java/src/com/ibm/streamsx/kafka/clients/consumer/CrKafkaConsumerGroupClient.java#L774-L813
In seekPartitions, invoked on RESET with the previously assigned partitions: The try-catch-block around
seek(line 778) catches the wrong exception (IllegalArgumentException, line 811) to capture the event that the seeked partition is not owned by the consumer anymore. The consumer throws an IllegalStateException when a partition is not owned anymore.