li-apache-kafka-clients is a wrapper library for the Apache Kafka vanilla clients. It provides additional features such as large message support and auditing to the Java producer and consumer in the open source Apache Kafka.
BSD 2-Clause "Simplified" License
131
stars
52
forks
source link
Add exception.on.invalid.offset config to allow throwing exception when auto.offset.reset is set to some policy #182
Add an exception.on.invalid.offset config to allow throw the InvalidOffsetException even when auto.offset.reset for LiKafkaConsumer is set to some policy (earliest/latest/liclosest). This is to allow users to handle this exception while let LiKafkaConsumer deal with the internal state of large message.
This is just a temporary solution and will be discarded when large message support has been refactored
Add an exception.on.invalid.offset config to allow throw the InvalidOffsetException even when auto.offset.reset for LiKafkaConsumer is set to some policy (earliest/latest/liclosest). This is to allow users to handle this exception while let LiKafkaConsumer deal with the internal state of large message.
This is just a temporary solution and will be discarded when large message support has been refactored