search

confluentinc / parallel-consumer

Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.
https://confluent.io/confluent-accelerators/#parallel-consumer
Apache License 2.0
689 stars 118 forks source link

Support Kafka-clients:3.7.0 #775

Closed dumontxiong closed 1 month ago

dumontxiong commented 1 month ago

Hi team io.confluent.parallelconsumer:parallel-consumer-core:0.2.5.8 not support Kafka-clients:3.7.0 Cause AbstractParallelEoSStreamProcessor.checkAutoCommitIsDisabled row 265 : Field coordinatorField = consumer.getClass().getDeclaredField("coordinator") will throw NoSuchFieldException. The RCA is KafkaConsumer（3.6.0） is very different with KafkaConsumer（3.7.0）,KafkaConsumer（3.7.0） doesn't contain coordinator and other fields BRs, Dumont

nscuro commented 1 month ago

Duplicate of #721, fixed in #762.