Uploaded image for project: 'Quarkus'
  1. Quarkus
  2. QUARKUS-4914

[io.sma.rea.mes.provider] (vert.x-eventloop-thread-3) SRMSG00201: Errojava.lang.ClassCastException: class org.eclipse.microprofile.reactive.messaging.Message$8 cannot be cast to class io.smallrye.reactive.messaging.kafka.KafkaRecordBatch

XMLWordPrintable

    • False
    • None
    • False
    • ---

      • The method annotated with @Incoming does not support KafkaRecordBatch anymore and it must be used one of the following: Message<List<Payload>>, Message<ConsumerRecords<Key, Payload>>, and ConsumerRecords<Key, Payload>
        Here there is not the possibility to retrieve the tracing metadata from the records, so making impossible to propagate the context.
        Reference documentation: https://quarkus.io/guides/kafka#receiving-kafka-records-in-batches
      - 2024-09-06 13:23:03,975 ERROR [io.sma.rea.mes.provider] (vert.x-eventloop-thread-3) SRMSG00201: Error caught while processing a message in method org.acme.MovieConsumer#consume: java.lang.ClassCastException: class org.eclipse.microprofile.reactive.messaging.Message$8 cannot be cast to class io.smallrye.reactive.messaging.kafka.KafkaRecordBatch (org.eclipse.microprofile.reactive.messaging.Message$8 and io.smallrye.reactive.messaging.kafka.KafkaRecordBatch are in unnamed module of loader io.quarkus.bootstrap.classloading.QuarkusClassLoader @14a2f921)

        1. Quarkus-kafka-rhel1.zip
          69 kB
        2. testApi_PR2754.zip
          63 kB
        3. with_transaction_testApi_PR2754.zip
          64 kB

              cescoffi@redhat.com Clement Escoffier
              rhn-support-kkakarla kodandaRamu kakarla
              Votes:
              1 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated: