Skip to content

Incompatible with kafka-clients 4.0.0 #420

@monosoul

Description

@monosoul

Expected Behavior

Reactor Kafka works with Kafka clients 4.0.0

Actual Behavior

org.apache.kafka.clients.consumer.ConsumerRecord's constructor signature changed in kafka-clients 4.0.0, and the constructor in reactor.kafka.receiver.ReceiverRecord now invokes a non existent method.

Steps to Reproduce

Put org.apache.kafka:kafka-clients:4.0.0 on the classpath and try to create an instance of reactor.kafka.receiver.ReceiverRecord.

Possible Solution

Update reactor.kafka.receiver.ReceiverRecord to fix the constructor invocation.

Your Environment

  • Reactor version(s) used: 1.3.23
  • Other relevant libraries versions (eg. netty, ...): kafka-clients 4.0.0
  • JVM version (java -version): 21

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions