NEERAJ VAIDYA created KAFKA-13383:
-
Summary: Consumer Group partition management across clusters
(Active-Active)
Key: KAFKA-13383
URL: https://issues.apache.org/jira/browse/KAFKA-13383
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NEERAJ VAIDYA resolved KAFKA-13292.
---
Resolution: Fixed
Upgraded the client libraries to 2.8.0 while still using 2.7.0 broker.
Us
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415491#comment-17415491
]
NEERAJ VAIDYA commented on KAFKA-13292:
---
Thanks [~mjsax]
I will look at upgrading
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415181#comment-17415181
]
NEERAJ VAIDYA commented on KAFKA-13292:
---
Thanks [~mjsax]
So, to summarize : Will
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NEERAJ VAIDYA reopened KAFKA-13292:
---
As indicated in my previous comments.
> InvalidPidMappingException: The producer attempted to u
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414732#comment-17414732
]
NEERAJ VAIDYA edited comment on KAFKA-13292 at 9/14/21, 5:49 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414732#comment-17414732
]
NEERAJ VAIDYA commented on KAFKA-13292:
---
Thanks [~mjsax] for the reference to the
NEERAJ VAIDYA created KAFKA-13292:
-
Summary: InvalidPidMappingException: The producer attempted to use
a producer id which is not currently assigned to its transactional id
Key: KAFKA-13292
URL: https://issues.apa
[
https://issues.apache.org/jira/browse/KAFKA-12972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NEERAJ VAIDYA updated KAFKA-12972:
--
Summary: KStreams - Rebalance not happening after new consumer member joins
group (was: KStre
NEERAJ VAIDYA created KAFKA-12972:
-
Summary: KStreams - Rebalance not happening
Key: KAFKA-12972
URL: https://issues.apache.org/jira/browse/KAFKA-12972
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NEERAJ VAIDYA resolved KAFKA-12776.
---
Resolution: Information Provided
KIP-739 has considerable of overlap with this issue.
> Pro
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348078#comment-17348078
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
[~ableegoldman], [~guozhang]
I am closin
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347269#comment-17347269
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks [~ableegoldman]
I'd imagined KIP-
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346805#comment-17346805
]
NEERAJ VAIDYA edited comment on KAFKA-12776 at 5/19/21, 1:45 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346805#comment-17346805
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
[~guozhang] I am keen to get such a featu
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345848#comment-17345848
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks [~guozhang]
To conclude, am I cor
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345828#comment-17345828
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks [~guozhang]
Will
[KIP-739|https:
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345814#comment-17345814
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
[~ijuma] Yes `send` is called from multip
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345804#comment-17345804
]
NEERAJ VAIDYA edited comment on KAFKA-12776 at 5/17/21, 12:44 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345804#comment-17345804
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
[~ijuma] The attempts to get metadata bec
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344958#comment-17344958
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
[~ableegoldman], [~ijuma], [~tombentley]
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344914#comment-17344914
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
[~tombentley]
Yes, this has been reprodu
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344517#comment-17344517
]
NEERAJ VAIDYA edited comment on KAFKA-12776 at 5/14/21, 12:51 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344517#comment-17344517
]
NEERAJ VAIDYA edited comment on KAFKA-12776 at 5/14/21, 12:51 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344517#comment-17344517
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Hi Tom
The topic has just 1 partition.
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344275#comment-17344275
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
To work around this, if I set _batch.size
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344271#comment-17344271
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks for updating the docs [~ableegoldm
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344188#comment-17344188
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks [~ableegoldman]
As [~ijuma] poin
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344153#comment-17344153
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks Sophie.
I did try with max infligh
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344126#comment-17344126
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks Sophie.
I assumed that if my messa
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343768#comment-17343768
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Here are the config values that I use in
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343746#comment-17343746
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Also, why does the Producer.send API call
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343682#comment-17343682
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Assuming that a Producer application is s
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NEERAJ VAIDYA updated KAFKA-12776:
--
Description:
I have an Apache Kafka 2.6 Producer which writes to topic-A (TA).
My applicatio
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NEERAJ VAIDYA updated KAFKA-12776:
--
Attachment: mocker.zip
> Producer sends messages out-of-order inspite of enabling idempotence
NEERAJ VAIDYA created KAFKA-12776:
-
Summary: Producer sends messages out-of-order inspite of enabling
idempotence
Key: KAFKA-12776
URL: https://issues.apache.org/jira/browse/KAFKA-12776
Project: Kafka
36 matches
Mail list logo