How to set the consumer group for event registry

Flowable Engine
1

Hi All,

Can I know what property in flowabl is used to form the consumer group id for Kafka?

I thought the property spring.kafka.consumer.group-id in application.properties should do the trick.

But in docker logs I am seeing this: -

group.id = org.flowable.eventregistry.kafka.ChannelKafkaListenerEndpointContainer#channelTimestone

where channelTimestone is the inboud channel key.

2

Hi @filiphr,

Can you please guide me?

3

Hey @sukalpo,

By default the group id from the consumer is derived from the key of the channel. However, you can configure this as well via the inbound channel definition. Have a look at KafkaInboundChannelModel for all the inbound channel options.

You can’t configure it via a system property. However, the groupId can be a Spring expression.

Cheers,
Filip

2 Likes
4

Hey @filiphr,
Does it mean we can remove the property in application.properties below:
spring.kafka.consumer.group-id=consumer-group-1

5

Hey @mykeul,

No you can’t remove it from there. The event-demo-sentiment-analysis-app is not using Flowable. This app is the one that is consuming the events send by the app using Flowable (event-demo-customer-case-app).

Cheers,
Filip

6

I thought it is indeed using Flowable as I see those channel/event files located here:

7

Sorry my bad, you are right. It does use Flowable. I checked the pom, but didn’t check the event-common-demo module. The consumer group id there shouldn’t be needed anymore, it isn’t used anymore.

8

Thanks Filip.

Cheers,
Michel