[JBoss JIRA] (DROOLS-4368) HACEP Refactor DefaultKafkaConsumer
by Daniele Zonca (Jira)
[ https://issues.jboss.org/browse/DROOLS-4368?page=com.atlassian.jira.plugi... ]
Daniele Zonca updated DROOLS-4368:
----------------------------------
Labels: HADrools (was: )
> HACEP Refactor DefaultKafkaConsumer
> -----------------------------------
>
> Key: DROOLS-4368
> URL: https://issues.jboss.org/browse/DROOLS-4368
> Project: Drools
> Issue Type: Task
> Components: core engine
> Reporter: Daniele Zonca
> Assignee: Massimiliano Dessi
> Priority: Major
> Labels: HADrools
>
> Try to uniform leader/replica flow:
> - If I'm the leader it invokes `defaultProcessAsLeader` -> `processLeader` -> `process/processWithSnapshot`
> - If I'm a replica it invokes `defaultProcessAsAReplica` -> `consumeEventsFromBufferAsAReplica` -> `processEventsAsAReplica` -> `process`
> Try to remove most/all boolean and use proper method parameter
> Verify defaultProcessAsAReplica else branch. This should never happen because if leader sent a message about process a specific event, it should be available
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 10 months