[eventregistry] Topic Name Change in same Channel file, stopping Consumer

Flowable Engine
1

Spring Boot Application with auto-deployment of eventregistry and processes from resources folder.

Issue (from log)

org.flowable.eventregistry.kafka.ChannelKafkaListenerEndpointContainer#eventInboundChannel: Consumer stopped

Content
Here are the 2 versions of the same channel file with a topic name changed.

  • eventInbound.channel file v1:

      {
    "key": "eventInboundChannel",
    "channelType": "inbound",
    "type": "kafka",
    "deserializerType": "json",
    "channelEventKeyDetection": {
      "fixedValue": "someEvent"
    },
    "topics": ["EVENT_RESULT"]
  }

  • eventInbound.channel file v2:

      {
    "key": "eventInboundChannel",
    "channelType": "inbound",
    "type": "kafka",
    "deserializerType": "json",
    "channelEventKeyDetection": {
      "fixedValue": "someEvent"
    },
    "topics": ["EVENT_SUCCESS"]
  }

Note
But when I drop the database and create again, new deployment works perfectly with consumer mapped to new Topic EVENT_SUCCESS

2

@filiphr/ @joram
Any pointers?

3

Hey @whyaneel,

I am not following. When you deploy a new version of your channel then we are going to stop the previous consumer and start a new one.

Can you please share more of your log so we can see more information?

Cheers,
Filip

4

I misread these logs, makes sense.

When you deploy a new version of your channel then we are going to stop the previous consumer and start a new one.