confluentinc / confluentinc/parallel-consumer
`checkAutoCommitIsDisabled` fails with kafka-clients < 3.7.0 when using consumer inherited from `KafkaConsumer`
- Dominant language
- Java
- Stars
- 299
- Forks
- 172
- PR merge metrics
- No merged PRs in 30d
Description
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
```java
...
Field coordinatorField = KafkaConsumer.class.getDeclaredField("coordinator");
...
```
in favour of
```java
...
final Field coordinatorField = consumerClass.getDeclaredField("coordinator"); //NoSuchFieldException
...
```
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
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.