confluentinc / confluentinc/parallel-consumer

`checkAutoCommitIsDisabled` fails with kafka-clients < 3.7.0 when using consumer inherited from `KafkaConsumer`

Open
#825 2 comments 0 reactions 0 assignees View on GitHub
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.