[ 
https://issues.apache.org/jira/browse/CAMEL-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312369#comment-17312369
 ] 

Claus Ibsen commented on CAMEL-16413:
-------------------------------------

Yeah its actually better to check for !isRunAllowed so I am doing a new commit 
for that.

> [camel-kafka] Avoid committing offsets onPartitionsRevoked during shutdown 
> when autoCommitOnStop is "none"
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-16413
>                 URL: https://issues.apache.org/jira/browse/CAMEL-16413
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-kafka
>    Affects Versions: 3.8.0
>            Reporter: Suneet Kumar
>            Assignee: Claus Ibsen
>            Priority: Major
>             Fix For: 3.10.0
>
>
> During shutdown process, whenever a partition is revoked, 
> `onPartitionsRevoked` method is called, which is forcing `commitSync`  even 
> when `autoCommitOnStop` is set to none.
>  
> ```
>  {{DEBUG org.apache.camel.component.kafka.KafkaConsumer: - 
> onPartitionsRevoked: **-Thread 0 from topic **}}
> {{DEBUG org.apache.camel.component.kafka.KafkaConsumer: - Forcing commitSync 
> **-Thread 0 from topic ** with offset: 31621}}
> ```
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to