Artur Denysenko created KAFKA-1585:
--
Summary: Client: Infinite conflict in /consumers/
Key: KAFKA-1585
URL: https://issues.apache.org/jira/browse/KAFKA-1585
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Artur Denysenko updated KAFKA-1585:
---
Description:
Periodically we have kafka consumers cycling in to conflict in /consumers/.
[
https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Artur Denysenko updated KAFKA-1585:
---
Component/s: consumer
Client: Infinite conflict in /consumers/
[
https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Artur Denysenko updated KAFKA-1585:
---
Description:
Periodically we have kafka consumers cycling in conflict in /consumers/ and
I
[
https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Artur Denysenko updated KAFKA-1585:
---
Priority: Critical (was: Major)
Client: Infinite conflict in /consumers/
[
https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1585:
-
Fix Version/s: 0.8.2
Client: Infinite conflict in /consumers/
[
https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092050#comment-14092050
]
Joe Stein commented on KAFKA-1585:
--
FWIW there were a lot of bug fixes released in the
[
https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092051#comment-14092051
]
Joe Stein commented on KAFKA-1451:
--
Hi, two issues so far where found with leader
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24006/#review50126
---
core/src/test/scala/unit/kafka/admin/AdminTest.scala
[
https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092203#comment-14092203
]
Jonathan Natkins commented on KAFKA-1420:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092205#comment-14092205
]
Jun Rao commented on KAFKA-1510:
Thinking about this a bit more, would it be more reliable
[
https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092207#comment-14092207
]
Artur Denysenko commented on KAFKA-1585:
I've tried with Zookeeper 3.4.6 - same
Jun Rao created KAFKA-1586:
--
Summary: support sticky partitioning in the new producer
Key: KAFKA-1586
URL: https://issues.apache.org/jira/browse/KAFKA-1586
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092237#comment-14092237
]
Jun Rao commented on KAFKA-1586:
One way to address this issue is introduce a new config
[
https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092253#comment-14092253
]
Jun Rao commented on KAFKA-1451:
Joe,
KAFKA-1387 seems to be related to broker
[
https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092255#comment-14092255
]
Jun Rao commented on KAFKA-1387:
Hmm, this seems really weird. Not sure why starting two
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24214/#review50128
---
core/src/main/scala/kafka/log/LogCleaner.scala
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24510/#review50127
---
Thanks for the patch. Could you take a look at the following
[
https://issues.apache.org/jira/browse/KAFKA-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092292#comment-14092292
]
Gopinath Sundaram commented on KAFKA-1587:
--
I found this issue
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1419.
Resolution: Fixed
Thanks for the patch. +1. Committed to trunk after fixing README and the 2.11
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24510/
---
(Updated Aug. 11, 2014, 4:23 a.m.)
Review request for kafka.
Bugs:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24006/#review50137
---
Thanks for the patch. One comment below.
[
https://issues.apache.org/jira/browse/KAFKA-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092428#comment-14092428
]
Dong Lin commented on KAFKA-1582:
-
Updated reviewboard
On Aug. 10, 2014, 11:44 p.m., Jun Rao wrote:
core/src/main/scala/kafka/log/LogCleaner.scala, lines 400-420
https://reviews.apache.org/r/24214/diff/4/?file=657033#file657033line400
Thinking about this a bit more. I am wondering if it would be better if
we introduce a per-topic
On Aug. 11, 2014, 12:06 a.m., Jun Rao wrote:
system_test/utils/kafka_system_test_utils.py, lines 1121-1124
https://reviews.apache.org/r/24510/diff/1/?file=656792#file656792line1121
Does this work as expected?
I tried the following test. However, the pid in the file tt
[
https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1574:
---
Summary: unit tests can hang on socketserver shutdown (was: unit tests can
hand on socketserver shutdown)
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24540/
---
Review request for kafka.
Bugs: KAFKA-1574
[
https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092436#comment-14092436
]
Jun Rao commented on KAFKA-1574:
Created reviewboard https://reviews.apache.org/r/24540/
[
https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1574:
---
Attachment: KAFKA-1574.patch
unit tests can hang on socketserver shutdown
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24540/#review50148
---
Ship it!
Ship It!
- Jay Kreps
On Aug. 11, 2014, 4:44 a.m., Jun
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24540/#review50157
---
Ship it!
Ship It!
- Guozhang Wang
On Aug. 11, 2014, 4:44 a.m.,
[
https://issues.apache.org/jira/browse/KAFKA-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092461#comment-14092461
]
Guozhang Wang commented on KAFKA-1588:
--
As have discussed with Todd, changing the map
On Aug. 10, 2014, 9:12 p.m., Jonathan Natkins wrote:
core/src/test/scala/unit/kafka/admin/AdminTest.scala, line 114
https://reviews.apache.org/r/24006/diff/3-4/?file=646111#file646111line114
I wasn't totally sure I understood this comment, so I made a change
that I think reflects
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24510/#review50159
---
Ship it!
Ship It!
- Guozhang Wang
On Aug. 11, 2014, 4:23 a.m.,
See https://builds.apache.org/job/Kafka-trunk/243/changes
35 matches
Mail list logo