[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vladimir Tretyakov updated KAFKA-1481:
--
Attachment: KAFKA-1481_2014-10-15_10-23-35.patch
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172118#comment-14172118
]
Vladimir Tretyakov commented on KAFKA-1481:
---
Added 2 patches (created with git
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172118#comment-14172118
]
Vladimir Tretyakov edited comment on KAFKA-1481 at 10/15/14 8:01 AM:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26710/#review56699
---
core/src/main/scala/kafka/server/KafkaApis.scala
On Oct. 15, 2014, 5:22 a.m., Joel Koshy wrote:
core/src/main/scala/kafka/server/KafkaApis.scala, line 510
https://reviews.apache.org/r/26710/diff/1/?file=721124#file721124line510
There is an issue here. The replica manager only contains information
about partitions that are
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172372#comment-14172372
]
Neha Narkhede commented on KAFKA-1637:
--
Wups. Didn't mean to push the patch for this
We have a requirement where in only one producer should be writing to a
partition at once.The producer will be managing it's own offsets, what it does
is at the time of startup gets latest offsets from Kafka and while producing
the messages it assigns this offsets to the message.For this we had
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172513#comment-14172513
]
Ewen Cheslack-Postava commented on KAFKA-1637:
--
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26710/
---
(Updated Oct. 15, 2014, 4:08 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1637:
-
Attachment: KAFKA-1637_2014-10-15_09:08:12.patch
SimpleConsumer.fetchOffset
Jiangjie Qin created KAFKA-1706:
---
Summary: Adding a byte bounded blocking queue to util.
Key: KAFKA-1706
URL: https://issues.apache.org/jira/browse/KAFKA-1706
Project: Kafka
Issue Type:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26755/
---
Review request for kafka.
Bugs: KAFKA-1706
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172533#comment-14172533
]
Jiangjie Qin commented on KAFKA-1706:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1706:
Attachment: KAFKA-1706.patch
Adding a byte bounded blocking queue to util.
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1706:
Status: Patch Available (was: Open)
Adding a byte bounded blocking queue to util.
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26755/
---
(Updated Oct. 15, 2014, 4:26 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1706:
Attachment: KAFKA-1706_2014-10-15_09:26:26.patch
Adding a byte bounded blocking queue to util.
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172540#comment-14172540
]
Jiangjie Qin commented on KAFKA-1706:
-
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26755/
---
(Updated Oct. 15, 2014, 4:28 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1706:
Attachment: KAFKA-1706_2014-10-15_09:28:01.patch
Adding a byte bounded blocking queue to util.
On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote:
core/src/main/scala/kafka/log/Log.scala, line 515
https://reviews.apache.org/r/26663/diff/2/?file=721126#file721126line515
Thinking about this a bit more: do you think it would be safer to
interpret jitter as an additive value to
On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote:
core/src/main/scala/kafka/log/Log.scala, line 515
https://reviews.apache.org/r/26663/diff/2/?file=721126#file721126line515
Thinking about this a bit more: do you think it would be safer to
interpret jitter as an additive value to
Hari created KAFKA-1707:
---
Summary: ConsumerOffsetChecker shows none partitions assigned
Key: KAFKA-1707
URL: https://issues.apache.org/jira/browse/KAFKA-1707
Project: Kafka
Issue Type: Bug
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26373/#review56736
---
Ship it!
Ship It!
- Guozhang Wang
On Oct. 13, 2014, 11:38 p.m.,
Hari created KAFKA-1708:
---
Summary: Consumers intermittently stop consuming till restart
Key: KAFKA-1708
URL: https://issues.apache.org/jira/browse/KAFKA-1708
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hari updated KAFKA-1707:
Description: bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker shows
some partitions having none consumers
Thanks Joe,
I think we now have a few open questions to discuss around this topic:
1. Shall we make core Kafka properties as first class fields in message
header or put them as tags?
The pros of the first approach is more compacted format and hence less
message header overhead; the cons are
On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote:
core/src/main/scala/kafka/log/Log.scala, line 515
https://reviews.apache.org/r/26663/diff/2/?file=721126#file721126line515
Thinking about this a bit more: do you think it would be safer to
interpret jitter as an additive value to
HI Jun,
I will file a Jira Bug for this and I will attach YourKit Profile Snapshot
and screen short. Do you want me take Thread dump each time second ?
Because the threads are blocked on SYNC code block like you mentioned and
the YourKit Profile snapshot will contain Thread dump.
Thanks,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26770/
---
Review request for kafka.
Bugs: KAFKA-1108
[
https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1108:
-
Attachment: KAFKA-1108.patch
when controlled shutdown attempt fails, the reason
[
https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1108:
-
Assignee: Ewen Cheslack-Postava
Status: Patch Available (was: Open)
when
[
https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172775#comment-14172775
]
Ewen Cheslack-Postava commented on KAFKA-1108:
--
Created reviewboard
On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote:
core/src/main/scala/kafka/log/Log.scala, line 515
https://reviews.apache.org/r/26663/diff/2/?file=721126#file721126line515
Thinking about this a bit more: do you think it would be safer to
interpret jitter as an additive value to
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26710/#review56802
---
Ship it!
Minor naming comment which we can take care of on
Let me add my view on #2 in less delicate terms than Guozhang did :)
When you¹re trying to run Kafka as a service, having to care about the
format of the message sucks. I have plenty of users who are just fine
using the Avro standard and play nice. Then I have a bunch of users who
don¹t want to
[
https://issues.apache.org/jira/browse/KAFKA-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172942#comment-14172942
]
Glen Mazza commented on KAFKA-1514:
---
Trunk is presently 0.8.3-SNAPSHOT:
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172968#comment-14172968
]
Neha Narkhede commented on KAFKA-1637:
--
[~ewencp] Your latest patch looks good. Once
[
https://issues.apache.org/jira/browse/KAFKA-1506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172977#comment-14172977
]
Glen Mazza commented on KAFKA-1506:
---
As Guozhang noted, the taking forever may have been
[
https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14172987#comment-14172987
]
Glen Mazza commented on KAFKA-1492:
---
This seems more appropriate for the Kafka user
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26710/
---
(Updated Oct. 15, 2014, 9:47 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173018#comment-14173018
]
Ewen Cheslack-Postava commented on KAFKA-1637:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1637:
-
Attachment: KAFKA-1637_2014-10-15_14:47:21.patch
SimpleConsumer.fetchOffset
Hi,
We have accumulated an impressive list of pretty major features in 0.8.2 -
Delete topic
Automated leader rebalancing
Controlled shutdown
Offset management
Parallel recovery
min.isr and
clean leader election
In the past, what has worked for major feature releases is a beta release
prior to a
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173157#comment-14173157
]
Jun Rao commented on KAFKA-1481:
Thanks for the patch. The IDEA one applies successfully
See https://builds.apache.org/job/Kafka-trunk/304/changes
Changes:
[neha.narkhede] KAFKA-1637 SimpleConsumer.fetchOffset returns wrong error code
when no offset exists for topic/partition/consumer group; reviewed by Neha
Narkhede and Joel Koshy
--
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24676/#review56843
---
Thanks for the patch. Looks good to me. I only have some minor
[
https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173210#comment-14173210
]
Jun Rao commented on KAFKA-1583:
Just reviewed it.
Joel,
Do you want to take another
[
https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173215#comment-14173215
]
Joel Koshy commented on KAFKA-1583:
---
Yes please. I will be able to do this on Friday.
Probably 3 thread dumps will be enough.
Thanks,
Jun
On Wed, Oct 15, 2014 at 11:26 AM, Bhavesh Mistry mistry.p.bhav...@gmail.com
wrote:
HI Jun,
I will file a Jira Bug for this and I will attach YourKit Profile Snapshot
and screen short. Do you want me take Thread dump each time second ?
Bhavesh Mistry created KAFKA-1710:
-
Summary: [New Java Producer Potential Deadlock] Producer Deadlock
when all messages is being sent to single partition
Key: KAFKA-1710
URL:
Bhavesh Mistry created KAFKA-1709:
-
Summary: [New Java Producer Potential Deadlock] Producer Deadlock
when all messages is being sent to single partition
Key: KAFKA-1709
URL:
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhavesh Mistry updated KAFKA-1710:
--
Attachment: TestNetworkDownProducer.java
Java Test Program to Reproduce this issue.
[New Java
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhavesh Mistry updated KAFKA-1710:
--
Attachment: Screen Shot 2014-10-15 at 9.09.06 PM.png
Screen Shot 2014-10-13 at
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173330#comment-14173330
]
Bhavesh Mistry commented on KAFKA-1710:
---
Here is out put of Yourkit:
{code}
Frozen
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173332#comment-14173332
]
Bhavesh Mistry commented on KAFKA-1710:
---
MORE OutPut:
{code}
Frozen threads found
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhavesh Mistry updated KAFKA-1710:
--
Attachment: Screen Shot 2014-10-15 at 9.14.15 PM.png
Your Kit Monitor Screen shot:
[New Java
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bhavesh Mistry updated KAFKA-1710:
--
Attachment: th15.dump
th14.dump
th13.dump
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173344#comment-14173344
]
Bhavesh Mistry commented on KAFKA-1710:
---
I am not able to attached yourkit profiler
Hi Jun,
I have entered all details into
https://issues.apache.org/jira/browse/KAFKA-1710.
Let me know if you need more details.
Thanks,
Bhavesh
On Wed, Oct 15, 2014 at 8:35 PM, Jun Rao jun...@gmail.com wrote:
Probably 3 thread dumps will be enough.
Thanks,
Jun
On Wed, Oct 15, 2014 at
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173344#comment-14173344
]
Bhavesh Mistry edited comment on KAFKA-1710 at 10/16/14 4:40 AM:
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173368#comment-14173368
]
Bhavesh Mistry edited comment on KAFKA-1710 at 10/16/14 4:54 AM:
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14173368#comment-14173368
]
Bhavesh Mistry commented on KAFKA-1710:
---
Here is property file used for testing:
63 matches
Mail list logo
