[
https://issues.apache.org/jira/browse/CAMEL-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claus Ibsen resolved CAMEL-19358.
---------------------------------
Fix Version/s: 4.6.0
Resolution: Cannot Reproduce
Okay so this seems to work on 4.6 which I have been using.
For example a yaml route where I can change the state via JMX and have send
message to kafka topic, while its suspended, and then on resume it pickup the
messages.
{code}
# camel-k: language=yaml
- beans:
- name: myCB
type: org.apache.camel.throttling.ThrottlingExceptionRoutePolicy
properties:
failureThreshold: 3
failureWindow: 5000
halfOpenAfter: 10000
keepOpen: true
stateLoggingLevel: "WARN"
- route:
routePolicy: myCB
from:
uri: "kafka:foobar?brokers=localhost:9092"
steps:
- to: "log:info?showAll=true&multiline=true"
{code}
> camel-kafka - Kafka consumer is still able to consume message with keepOpen
> as true in ThrottlingExceptionRoutePolicy
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: CAMEL-19358
> URL: https://issues.apache.org/jira/browse/CAMEL-19358
> Project: Camel
> Issue Type: Bug
> Components: camel-kafka
> Affects Versions: 3.18.3, 3.20.0
> Reporter: Jianbo Ma
> Assignee: Claus Ibsen
> Priority: Minor
> Fix For: 4.6.0
>
>
> We have circuit breaker implementation in routes, and it is using
> ThrottlingExceptionRoutePolicy. Previously we were using version 3.18.0, the
> Kakfa consumer is not able to consume messages when keepOpen is true. However
> there was an issue with version 3.18.0, which was that the consumer couldn't
> be resumed after we changed the keepOpen to false, could be an issue related
> to https://issues.apache.org/jira/browse/CAMEL-18688 . We tried version
> 3.18.3 and 3.20.0, both versions have the same issue, Kafka consumer is able
> to consume message even with keepOpen as true, while for the route with JMS
> consumer, there is no such issue.
> Thanks,
> Jianbo
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
