You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Consumer configuration validation fails on checking auto commit is disabled when using consumer inherited from KafkaConsumer with kafka-clients 3.7.0.
There was an issue (#195 ) that fixed problem with inherited consumer and also test was added for this case, but now it's seems like this case is broken with kafka-clients < 3.7.0. I guess it is broken because in #721 this reflection stuff was removed
and now it will fail when getting coordinator field if it defined in super class
I know there is a workaround in face of io.confluent.parallelconsumer.ParallelConsumerOptions#ignoreReflectiveAccessExceptionsForAutoCommitDisabledCheck and I will use it until this issue will be fixed
The text was updated successfully, but these errors were encountered:
Consumer configuration validation fails on checking auto commit is disabled when using consumer inherited from
KafkaConsumer
with kafka-clients 3.7.0.There was an issue (#195 ) that fixed problem with inherited consumer and also test was added for this case, but now it's seems like this case is broken with kafka-clients < 3.7.0. I guess it is broken because in #721 this reflection stuff was removed
in favour of
and now it will fail when getting
coordinator
field if it defined in super classI know there is a workaround in face of
io.confluent.parallelconsumer.ParallelConsumerOptions#ignoreReflectiveAccessExceptionsForAutoCommitDisabledCheck
and I will use it until this issue will be fixedThe text was updated successfully, but these errors were encountered: