[jira] [Commented] (CAMEL-16790) camel-pulsar is prone to uneven message distribution with large backlog

[ https://issues.apache.org/jira/browse/CAMEL-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376845#comment-17376845 ] Kai Levy commented on CAMEL-16790: -- [~davsclaus] agree that it is a pulsar issue but I haven't had much

[jira] [Commented] (CAMEL-16790) camel-pulsar is prone to uneven message distribution with large backlog

[ https://issues.apache.org/jira/browse/CAMEL-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377427#comment-17377427 ] Kai Levy commented on CAMEL-16790: -- Yes, I will look at implementing a fix in the next couple weeks >

[jira] [Created] (CAMEL-16790) camel-pulsar is prone to uneven message distribution with large backlog

Kai Levy created CAMEL-16790: Summary: camel-pulsar is prone to uneven message distribution with large backlog Key: CAMEL-16790 URL: https://issues.apache.org/jira/browse/CAMEL-16790 Project: Camel

[jira] [Commented] (CAMEL-16790) camel-pulsar is prone to uneven message distribution with large backlog

[ https://issues.apache.org/jira/browse/CAMEL-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388264#comment-17388264 ] Kai Levy commented on CAMEL-16790: -- PR is up: [https://github.com/apache/camel/pull/5872]   Let me

[jira] [Commented] (CAMEL-16790) camel-pulsar is prone to uneven message distribution with large backlog

[ https://issues.apache.org/jira/browse/CAMEL-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387356#comment-17387356 ] Kai Levy commented on CAMEL-16790: -- [~davsclaus] I've worked on a fix that is mostly complete (just

[jira] [Commented] (CAMEL-16790) camel-pulsar is prone to uneven message distribution with large backlog

[ https://issues.apache.org/jira/browse/CAMEL-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387371#comment-17387371 ] Kai Levy commented on CAMEL-16790: -- OK, sounds good. Do I need to change anything to mark the fix as

[jira] [Commented] (CAMEL-17986) Camel pulsar consumer support key shared policy

[ https://issues.apache.org/jira/browse/CAMEL-17986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526617#comment-17526617 ] Kai Levy commented on CAMEL-17986: -- Realized that converting from string URI to a KeySharedPolicy isn't

[jira] [Updated] (CAMEL-17986) Camel pulsar consumer support key shared policy

[ https://issues.apache.org/jira/browse/CAMEL-17986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Levy updated CAMEL-17986: - Description: When using a key-shared subscription in pulsar, the consumer should be able to specify a

[jira] [Created] (CAMEL-17986) Camel pulsar consumer support key shared policy

Kai Levy created CAMEL-17986: Summary: Camel pulsar consumer support key shared policy Key: CAMEL-17986 URL: https://issues.apache.org/jira/browse/CAMEL-17986 Project: Camel Issue Type: New