Skip to content

spring-cloud-starter-bus-kafka dependency breaks consumer message channel #268

@APletenev

Description

@APletenev

Describe the bug
Spring Boot : 3.1.2
Spring Cloud : 2022.0.4

Application uses spring-cloud-stream-binder-kafka and Kafka consumers in functional style.
Adding the spring-cloud-starter-bus-kafka dependency lead to consumer message channel stop registering.
Removing the dependency, results again in a working application

Logs diff

without dependency:

o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel signup-in-0
ConsumerConfig values: client.id = consumer-user1-1
group.id = user1

with dependency:

o.s.i.monitor.IntegrationMBeanExporter : Registering MessageChannel springCloudBusInput
client.id = consumer-anonymous.3c0d339a-2479-46bc-b8ae-77d4e20929a2-1
group.id = anonymous.3c0d339a-2479-46bc-b8ae-77d4e20929a2

Sample
https://github.com/APletenev/microservice_template/tree/Cloud_Stream/idp

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions