[
https://issues.apache.org/jira/browse/KAFKA-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126023#comment-17126023
]
Jun Rao commented on KAFKA-10101:
-
[~ijuma] : Could you double check if this is an issue
[
https://issues.apache.org/jira/browse/KAFKA-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126036#comment-17126036
]
Jun Rao commented on KAFKA-10101:
-
If this is an issue, one way to fix that is to simply
[
https://issues.apache.org/jira/browse/KAFKA-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10106.
-
Fix Version/s: 2.7.0
Assignee: NIKHIL
Resolution: Fixed
Merged the PR to trunk.
> log t
[
https://issues.apache.org/jira/browse/KAFKA-10027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10027.
-
Fix Version/s: 2.7.0
Assignee: Kowshik Prakasam
Resolution: Fixed
merged the PR to trunk
[
https://issues.apache.org/jira/browse/KAFKA-12552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12552.
-
Fix Version/s: 3.0.0
Resolution: Fixed
Merged the PR to trunk.
> Extract segments map out of Log
[
https://issues.apache.org/jira/browse/KAFKA-12571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12571.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk
> Eliminate LeaderEpochFileCache c
[
https://issues.apache.org/jira/browse/KAFKA-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12575.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk
> Eliminate Log.isLogDirOffline bo
[
https://issues.apache.org/jira/browse/KAFKA-3968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-3968.
Fix Version/s: 3.0.0
Assignee: Cong Ding
Resolution: Fixed
Merged to trunk. Thanks Cong for
[
https://issues.apache.org/jira/browse/KAFKA-12368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12368.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk
> Inmemory implementation of RSM a
[
https://issues.apache.org/jira/browse/KAFKA-12553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12553.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk
> Refactor Log layer recovery logi
[
https://issues.apache.org/jira/browse/KAFKA-12429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12429.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk
> Serdes for all message types in
[
https://issues.apache.org/jira/browse/KAFKA-12757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342023#comment-17342023
]
Jun Rao commented on KAFKA-12757:
-
[~satish.duggana]: The implementation of server side
[
https://issues.apache.org/jira/browse/KAFKA-12758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12758.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk
> Create a new `server-common` mod
[
https://issues.apache.org/jira/browse/KAFKA-9826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342904#comment-17342904
]
Jun Rao commented on KAFKA-9826:
[~zhangzs] : The issue was fixed in 2.4.2. Could you try
[
https://issues.apache.org/jira/browse/KAFKA-3968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344701#comment-17344701
]
Jun Rao commented on KAFKA-3968:
Merged the reworked PR [https://github.com/apache/kafka/
[
https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350551#comment-17350551
]
Jun Rao commented on KAFKA-8522:
latest PR link
> Tombstones can survive forever
> -
[
https://issues.apache.org/jira/browse/KAFKA-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234891#comment-17234891
]
Jun Rao commented on KAFKA-10734:
-
[~luwang], thanks for the jira. In practice, if n is
[
https://issues.apache.org/jira/browse/KAFKA-10723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10723.
-
Fix Version/s: 2.8.0
Resolution: Fixed
merged to trunk
> LogManager leaks internal thread pool a
[
https://issues.apache.org/jira/browse/KAFKA-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10832.
-
Fix Version/s: 2.8.0
Resolution: Fixed
Merged the PR to trunk.
> Recovery logic is using incorre
[
https://issues.apache.org/jira/browse/KAFKA-10760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249409#comment-17249409
]
Jun Rao commented on KAFKA-10760:
-
[~kbrajesh176]: For max.compaction.lag.ms, we simply
[
https://issues.apache.org/jira/browse/KAFKA-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-9393:
---
Fix Version/s: (was: 2.7.0)
2.8.0
> DeleteRecords may cause extreme lock contention fo
[
https://issues.apache.org/jira/browse/KAFKA-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249973#comment-17249973
]
Jun Rao commented on KAFKA-9087:
Not sure if this is exactly the reason, but we did fix a
[
https://issues.apache.org/jira/browse/KAFKA-10759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250438#comment-17250438
]
Jun Rao commented on KAFKA-10759:
-
[~xiaopenglei]: Thanks for the jira. Perhaps we can f
[
https://issues.apache.org/jira/browse/KAFKA-10853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250568#comment-17250568
]
Jun Rao commented on KAFKA-10853:
-
[~ambroff] : Thanks for reporting this. I agree that
[
https://issues.apache.org/jira/browse/KAFKA-10888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254596#comment-17254596
]
Jun Rao commented on KAFKA-10888:
-
[~jr981008]: Thanks for reporting this. There are a c
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259314#comment-17259314
]
Jun Rao commented on KAFKA-2729:
If you still see this issue, it would be useful to confi
Jun Rao created KAFKA-12153:
---
Summary: follower can hit OffsetOutOfRangeException during
truncation
Key: KAFKA-12153
URL: https://issues.apache.org/jira/browse/KAFKA-12153
Project: Kafka
Issue Typ
[
https://issues.apache.org/jira/browse/KAFKA-10759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262814#comment-17262814
]
Jun Rao commented on KAFKA-10759:
-
[~xiaopenglei] : Thanks for your help. Perhaps you co
[
https://issues.apache.org/jira/browse/KAFKA-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263020#comment-17263020
]
Jun Rao commented on KAFKA-12176:
-
Another complication in the previous discussion was w
[
https://issues.apache.org/jira/browse/KAFKA-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-8018:
--
Assignee: Jun Rao
> Flaky Test
> SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrRetur
[
https://issues.apache.org/jira/browse/KAFKA-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782210#comment-16782210
]
Jun Rao commented on KAFKA-8018:
Created a PR: https://github.com/apache/kafka/pull/6354
[
https://issues.apache.org/jira/browse/KAFKA-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782211#comment-16782211
]
Jun Rao commented on KAFKA-7977:
The PR in https://issues.apache.org/jira/browse/KAFKA-80
[
https://issues.apache.org/jira/browse/KAFKA-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-8022:
--
Assignee: Jun Rao
> Flaky Test RequestQuotaTest#testExemptRequestTime
> --
[
https://issues.apache.org/jira/browse/KAFKA-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783838#comment-16783838
]
Jun Rao commented on KAFKA-8022:
The fsync to ZK txn log can take 10+ secs. Filed
[https
[
https://issues.apache.org/jira/browse/KAFKA-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-8022.
Resolution: Fixed
Fix Version/s: (was: 0.11.0.4)
2.2.1
2.3.
[
https://issues.apache.org/jira/browse/KAFKA-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-7977.
Resolution: Fixed
The PR in KAFKA-8018 is merged, which should reduce the chance for ZK session
expiration
[
https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791910#comment-16791910
]
Jun Rao commented on KAFKA-6029:
[~hzxa21], do you still plan to work on this? Thanks.
>
[
https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795523#comment-16795523
]
Jun Rao commented on KAFKA-7504:
[~cwaldrop], thanks for helping test this out. It would
[
https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16802074#comment-16802074
]
Jun Rao commented on KAFKA-7504:
[~cwaldrop], thanks for the results. It does seem to be
[
https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16805539#comment-16805539
]
Jun Rao commented on KAFKA-8106:
[~Flower.min], one of the validation that the broker has
[
https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810370#comment-16810370
]
Jun Rao commented on KAFKA-7983:
[~huxi_2b], leader.replication.throttled.replicas and
f
[
https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811005#comment-16811005
]
Jun Rao commented on KAFKA-7983:
Probably. But I think the common broker level setting wi
[
https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-7983:
--
Assignee: Rahul Agarwal
> supporting replication.throttled.replicas in dynamic broker configuration
>
[
https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812556#comment-16812556
]
Jun Rao commented on KAFKA-7983:
[~rahul.mnit], just added you to the contributor list an
[
https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856233#comment-16856233
]
Jun Rao commented on KAFKA-7504:
[~allenxwang], there is a PR attached to the jira. I gue
[
https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859031#comment-16859031
]
Jun Rao commented on KAFKA-7504:
[~allenxwang], thanks for doing the test and sharing the
[
https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16862569#comment-16862569
]
Jun Rao commented on KAFKA-7504:
[~allenxwang], thanks for the update. A couple of more t
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16863468#comment-16863468
]
Jun Rao commented on KAFKA-8532:
[~lbdai3190], thanks for reporting the issue. From the s
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864184#comment-16864184
]
Jun Rao commented on KAFKA-8532:
[~lbdai3190], expiryScheduler.shutdown() is probably not
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865744#comment-16865744
]
Jun Rao commented on KAFKA-8532:
[~lbdai3190], if this issue happens again, it would be u
[
https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16874578#comment-16874578
]
Jun Rao commented on KAFKA-8522:
[~EeveeB], thanks for reporting this. This is related to
[
https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877341#comment-16877341
]
Jun Rao commented on KAFKA-8522:
[~dhruvilshah] mentioned that the original timestamp of
[
https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878247#comment-16878247
]
Jun Rao commented on KAFKA-8522:
Since we are returning the tombstone to the consumer, it
[
https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051273#comment-16051273
]
Jun Rao commented on KAFKA-5413:
[~Kelvinrutt], yes, getting the last offset from the inde
[
https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051289#comment-16051289
]
Jun Rao commented on KAFKA-5007:
[~huxi_2b], that's a good thought. If we hit an unhandled
[
https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16054686#comment-16054686
]
Jun Rao commented on KAFKA-5431:
[~crietz], in Log.roll(), we call LogSegment.trim() to re
Jun Rao created KAFKA-5473:
--
Summary: handle ZK session expiration properly when a new session
can't be established
Key: KAFKA-5473
URL: https://issues.apache.org/jira/browse/KAFKA-5473
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16054757#comment-16054757
]
Jun Rao commented on KAFKA-5473:
The simplest solution is to just fail the broker if the n
[
https://issues.apache.org/jira/browse/KAFKA-2405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16054764#comment-16054764
]
Jun Rao commented on KAFKA-2405:
Just realized this change. This seems to cause the ZK ses
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16054781#comment-16054781
]
Jun Rao commented on KAFKA-5473:
One thing to note is that the construction of the ZooKeep
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16054960#comment-16054960
]
Jun Rao commented on KAFKA-5473:
Yes, the issue is there since KAFKA-2405 was committed. S
[
https://issues.apache.org/jira/browse/KAFKA-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055846#comment-16055846
]
Jun Rao commented on KAFKA-1561:
[~vinayak10], currently, duplicates can be introduced dur
[
https://issues.apache.org/jira/browse/KAFKA-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16056172#comment-16056172
]
Jun Rao commented on KAFKA-5480:
[~pengwei], thanks for reporting this. The issue seems to
[
https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-5413:
--
Assignee: Kelvin Rutt
> Log cleaner fails due to large offset in segment file
> ---
[
https://issues.apache.org/jira/browse/KAFKA-5491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-5491.
Resolution: Fixed
Fix Version/s: 0.11.0.0
Issue resolved by pull request 3400
[https://github.com/apa
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16060110#comment-16060110
]
Jun Rao commented on KAFKA-2729:
[~timoha], we are trying to address the ZK session expira
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16060973#comment-16060973
]
Jun Rao commented on KAFKA-5473:
[~prasincs], yes, the simplest solution is for the broker
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16061578#comment-16061578
]
Jun Rao commented on KAFKA-5473:
We could retry up to zk.connection.time.ms and then give
[
https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16063228#comment-16063228
]
Jun Rao commented on KAFKA-5413:
Merged https://github.com/apache/kafka/pull/3397 to 0.10.
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16063437#comment-16063437
]
Jun Rao commented on KAFKA-5473:
[~prasincs], there are a couple cases to consider. (1) Th
[
https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16063579#comment-16063579
]
Jun Rao commented on KAFKA-3806:
[~shangdi], good point on the issue with mirrormaker. I h
[
https://issues.apache.org/jira/browse/KAFKA-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069126#comment-16069126
]
Jun Rao commented on KAFKA-5542:
We can clarify the following.
"During the upgrade phase
[
https://issues.apache.org/jira/browse/KAFKA-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-5542.
Resolution: Fixed
Fix Version/s: 0.11.1.0
Issue resolved by pull request 3468
[https://github.com/apa
[
https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16078619#comment-16078619
]
Jun Rao commented on KAFKA-1120:
[~wushujames], it seems that problem that you reproduced
[
https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-5431.
Resolution: Fixed
Fix Version/s: 0.11.1.0
Issue resolved by pull request 3525
[https://github.com/apa
[
https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-5501.
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3427
[https://github.com/apache
Jun Rao created KAFKA-5706:
--
Summary: log the name of the error instead of the error code in
response objects
Key: KAFKA-5706
URL: https://issues.apache.org/jira/browse/KAFKA-5706
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16125827#comment-16125827
]
Jun Rao commented on KAFKA-5473:
[~braedon], yes, this is the same issue as described in K
[
https://issues.apache.org/jira/browse/KAFKA-3984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-3984.
Resolution: Duplicate
Marking this as duplicate. The fix will be done in KAFKA-5473.
> Broker doesn't retry
Jun Rao created KAFKA-5745:
--
Summary: Partition.makeLeader() should convert HW to
OffsetMetadata before becoming the leader
Key: KAFKA-5745
URL: https://issues.apache.org/jira/browse/KAFKA-5745
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16129725#comment-16129725
]
Jun Rao commented on KAFKA-5745:
The HW in the follower only includes the offset, but not
[
https://issues.apache.org/jira/browse/KAFKA-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16140278#comment-16140278
]
Jun Rao commented on KAFKA-5781:
It would also be useful to know the producer latency brea
[
https://issues.apache.org/jira/browse/KAFKA-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16140402#comment-16140402
]
Jun Rao commented on KAFKA-5781:
The metrics are described in http://kafka.apache.org/docu
[
https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142338#comment-16142338
]
Jun Rao commented on KAFKA-1120:
[~wushujames], just increasing controlled.shutdown.retry.
[
https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142400#comment-16142400
]
Jun Rao commented on KAFKA-1120:
Yes, that's the right metric. The only down side of incre
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16156120#comment-16156120
]
Jun Rao commented on KAFKA-2729:
[~davispw], the issue due to ZK session expiration will b
[
https://issues.apache.org/jira/browse/KAFKA-3039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16157087#comment-16157087
]
Jun Rao commented on KAFKA-3039:
Hmm, interesting. Not sure why this is happening. Current
Jun Rao created KAFKA-5858:
--
Summary: consumer.poll() shouldn't throw exception due to
deserialization error
Key: KAFKA-5858
URL: https://issues.apache.org/jira/browse/KAFKA-5858
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16157902#comment-16157902
]
Jun Rao commented on KAFKA-5858:
[~hachikuji], any caveats for doing this?
> consumer.pol
Jun Rao created KAFKA-5871:
--
Summary: bound the throttle time in byte rate quota
Key: KAFKA-5871
URL: https://issues.apache.org/jira/browse/KAFKA-5871
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186792#comment-16186792
]
Jun Rao commented on KAFKA-5758:
[~dwvangeest], the problem you described could happen tra
[
https://issues.apache.org/jira/browse/KAFKA-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16188465#comment-16188465
]
Jun Rao commented on KAFKA-5758:
[~dwvangeest], thanks for the info. I agree that it's bet
[
https://issues.apache.org/jira/browse/KAFKA-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-5995.
Resolution: Fixed
Fix Version/s: 1.0.0
Issue resolved by pull request 3993
[https://github.com/apache
[
https://issues.apache.org/jira/browse/KAFKA-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16190609#comment-16190609
]
Jun Rao commented on KAFKA-5758:
[~dwvangeest], thanks for the info.
> Reassigning a topi
[
https://issues.apache.org/jira/browse/KAFKA-5767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-5767.
Resolution: Fixed
Issue resolved by pull request 3718
[https://github.com/apache/kafka/pull/3718]
> Kafka s
[
https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192247#comment-16192247
]
Jun Rao commented on KAFKA-5473:
The PR is in https://github.com/apache/kafka/pull/3990. W
[
https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198036#comment-16198036
]
Jun Rao commented on KAFKA-5140:
Saw the following transient failures in a recent PR build
[
https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199314#comment-16199314
]
Jun Rao commented on KAFKA-6029:
One of the issues that can lead to this is that the follo
[
https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199316#comment-16199316
]
Jun Rao commented on KAFKA-6028:
Another way to address this is what's described in
https
[
https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199792#comment-16199792
]
Jun Rao commented on KAFKA-6028:
[~becket_qin], the window size is configurable and we can
201 - 300 of 522 matches
Mail list logo
