Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Kafka DLQ config doesn't work will concurrency enabled topics #2766

Open
ozangunalp opened this issue Sep 25, 2024 · 0 comments
Open

Kafka DLQ config doesn't work will concurrency enabled topics #2766

ozangunalp opened this issue Sep 25, 2024 · 0 comments
Labels
bug Something isn't working kafka

Comments

@ozangunalp
Copy link
Collaborator

When concurrency is enabled, the DLQ producer config doesn't get the correct properties from the main channel config.

Example config :

mp:
  messaging:
    incoming:
      material-batch-reader:
        connector: smallrye-kafka
        concurrency: 5
        health-topic-verification-enabled: true
        throttled:
          unprocessed-record-max-age:
            ms: 100000
        bootstrap:
          servers: ${my.bootstrap.url}
        sasl:
          jaas:
            config: 'org.apache.kafka.common.security.plain.PlainLoginModule required username="${myusername}" password="${mypassword}";'
        group:
          id: ${myconsumergroup}
        topic: com.mydomain.mytopicname
        key:
          deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
        value:
          deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
        fail-on-deserialization-failure: false
        failure-strategy: dead-letter-queue
        dead-letter-queue:
          topic: com.mydomain.dlq.mytopicname
          key:
            serializer: org.apache.kafka.common.serialization.ByteArraySerializer
          value:
            serializer: org.apache.kafka.common.serialization.ByteArraySerializer

Reported by : https://quarkusio.zulipchat.com/#narrow/stream/187030-users/topic/smallrye-reactive-messaging-kafka.3A.20DLQ.20.2B.20concurrency/near/472725895

@ozangunalp ozangunalp added bug Something isn't working kafka labels Sep 25, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working kafka
Projects
None yet
Development

No branches or pull requests

1 participant