[
https://issues.apache.org/jira/browse/KAFKA-345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14211996#comment-14211996
]
Jiangjie Qin commented on KAFKA-345:
There are some other considerations regarding
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212011#comment-14212011
]
Stevo Slavic commented on KAFKA-1764:
-
Is this issue duplicate of KAFKA-1716 ?
[
https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212082#comment-14212082
]
Stevo Slavic commented on KAFKA-1716:
-
Is this issue related to KAFKA-1764 ? That one
[
https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212171#comment-14212171
]
Jing Dong commented on KAFKA-1194:
--
Are there anyway to fix the exception in current
[
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-11-14_16-39-41_doc.patch
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212264#comment-14212264
]
Vladimir Tretyakov commented on KAFKA-1481:
---
Hi, added new patches (code + doc),
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212267#comment-14212267
]
Chris Cope commented on KAFKA-1764:
---
This now builds and all 547 tests pass. Thanks!
[
https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212425#comment-14212425
]
Jiangjie Qin commented on KAFKA-1716:
-
I don't think they are related. KAFKA-1764 only
Jiangjie Qin created KAFKA-1770:
---
Summary: The description of UnknownTopicOrPartitionException in
doc is not accurate.
Key: KAFKA-1770
URL: https://issues.apache.org/jira/browse/KAFKA-1770
Project:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28040/
---
Review request for kafka.
Bugs: KAFKA-1770
[
https://issues.apache.org/jira/browse/KAFKA-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1770:
Assignee: Jiangjie Qin
Status: Patch Available (was: Open)
The description of
[
https://issues.apache.org/jira/browse/KAFKA-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212474#comment-14212474
]
Jiangjie Qin commented on KAFKA-1770:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1770:
Attachment: KAFKA-1770.patch
The description of UnknownTopicOrPartitionException in doc is not
[
https://issues.apache.org/jira/browse/KAFKA-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212477#comment-14212477
]
Dmytro Kostiuchenko commented on KAFKA-1667:
Bump. Anyone willing to review?
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27684/
---
(Updated Nov. 14, 2014, 5 p.m.)
Review request for kafka.
Bugs: KAFKA-1743
[
https://issues.apache.org/jira/browse/KAFKA-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-1743:
---
Attachment: KAFKA-1743_2014-11-14_22:29:21.patch
ConsumerConnector.commitOffsets in 0.8.2 is
[
https://issues.apache.org/jira/browse/KAFKA-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212481#comment-14212481
]
Manikumar Reddy commented on KAFKA-1743:
Updated reviewboard
On Nov. 10, 2014, 7:50 p.m., Jun Rao wrote:
core/src/main/scala/kafka/consumer/ConsumerConnector.scala, lines 76-80
https://reviews.apache.org/r/27684/diff/2/?file=755292#file755292line76
We will also need to change the interface in ConsumerConnector from
def
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212511#comment-14212511
]
Ashish Kumar Singh commented on KAFKA-313:
--
[~jjkoshy] I am planning to take a
[
https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212515#comment-14212515
]
Michael Herstine commented on KAFKA-1684:
-
Coming in a little late, but to the
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212527#comment-14212527
]
Joel Koshy commented on KAFKA-313:
--
I'm not sure if there is a strong need for this. In
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy reassigned KAFKA-313:
Assignee: Ashish Kumar Singh
Add JSON output and looping options to ConsumerOffsetChecker
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-313:
-
Reviewer: Joel Koshy
Add JSON output and looping options to ConsumerOffsetChecker
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212536#comment-14212536
]
Jun Rao commented on KAFKA-1481:
Thanks for the patch. Appreciate your persistence. A few
[
https://issues.apache.org/jira/browse/KAFKA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212560#comment-14212560
]
Ewen Cheslack-Postava commented on KAFKA-1745:
--
[~Vishal M] I'm not sure what
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212563#comment-14212563
]
Jun Rao commented on KAFKA-1481:
83. On another thought, the port tag may be ok since a
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1764:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
ZookeeperConsumerConnector could
Ewen Cheslack-Postava created KAFKA-1771:
Summary: replicate_testsuite data verification broken if
num_partitions replica_factor
Key: KAFKA-1771
URL: https://issues.apache.org/jira/browse/KAFKA-1771
[
https://issues.apache.org/jira/browse/KAFKA-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212593#comment-14212593
]
Ewen Cheslack-Postava commented on KAFKA-1763:
--
[~mgharat] Again, this is
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212598#comment-14212598
]
Vladimir Tretyakov commented on KAFKA-1481:
---
Thx Jun, will try to fix everything
[
https://issues.apache.org/jira/browse/KAFKA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212602#comment-14212602
]
Scott Hunt commented on KAFKA-948:
--
I think I just ran into this same issue on our cluster
HI Kafka Team,
We like to enforce a network bandwidth quota limit per minute on producer
side. How can I do this ? I need some way to count compressed bytes on
producer ? I know there is callback does not give this ability ? Let me
know the best way.
Thanks,
Bhavesh
[
https://issues.apache.org/jira/browse/KAFKA-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212611#comment-14212611
]
Ewen Cheslack-Postava commented on KAFKA-1721:
--
[~junrao] This is a trivial
[
https://issues.apache.org/jira/browse/KAFKA-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava reassigned KAFKA-1771:
Assignee: Ewen Cheslack-Postava
replicate_testsuite data verification
[
https://issues.apache.org/jira/browse/KAFKA-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1721:
-
Fix Version/s: 0.8.2
Snappy compressor is not thread safe
[
https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1642:
-
Reviewer: Jun Rao (was: Jay Kreps)
[Java New Producer Kafka Trunk] CPU Usage
[
https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212635#comment-14212635
]
Ewen Cheslack-Postava commented on KAFKA-1642:
--
[~junrao] I think you
[
https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1642:
-
Fix Version/s: 0.8.2
[Java New Producer Kafka Trunk] CPU Usage Spike to 100% when network
connection
[
https://issues.apache.org/jira/browse/KAFKA-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1764:
-
Fix Version/s: 0.8.2
ZookeeperConsumerConnector could put multiple shutdownCommand to the same
data
[
https://issues.apache.org/jira/browse/KAFKA-1762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1762:
-
Fix Version/s: 0.8.3
Update max-inflight-request doc string
--
[
https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1692:
-
Fix Version/s: 0.8.2
[Java New Producer] IO Thread Name Must include Client ID
[
https://issues.apache.org/jira/browse/KAFKA-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1719:
-
Fix Version/s: 0.8.2
Make mirror maker exit when one consumer/producer thread exits.
[
https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1706:
-
Fix Version/s: 0.8.2
Adding a byte bounded blocking queue to util.
[
https://issues.apache.org/jira/browse/KAFKA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1668:
-
Fix Version/s: 0.8.3
TopicCommand doesn't warn if --topic argument doesn't match any topics
[
https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1648:
-
Fix Version/s: 0.8.3
Round robin consumer balance throws an NPE when there are no topics
[
https://issues.apache.org/jira/browse/KAFKA-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1641:
-
Fix Version/s: 0.8.3
Log cleaner exits if last cleaned offset is lower than earliest offset
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1637:
-
Fix Version/s: 0.8.2
SimpleConsumer.fetchOffset returns wrong error code when no offset exists for
[
https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1597:
-
Fix Version/s: 0.8.2
New metrics: ResponseQueueSize and BeingSentResponses
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1580:
-
Fix Version/s: 0.8.2
Reject producer requests to internal topics
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27684/#review61486
---
Thanks for the patch. For clarity, in ZookeeperConsumerConnector,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27818/#review61488
---
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala
[
https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212697#comment-14212697
]
Neha Narkhede commented on KAFKA-328:
-
[~balaji.sesha...@dish.com] Reviewed. Left a
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy reopened KAFKA-1580:
---
Assignee: Guozhang Wang (was: Jonathan Natkins)
Reject producer requests to internal topics
[
https://issues.apache.org/jira/browse/KAFKA-1580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212811#comment-14212811
]
Joel Koshy commented on KAFKA-1580:
---
[~guozhang] I believe this change got lost as part
I just wanted to follow-up on a fall-out caused by the issue mentioned
below. After the offset manager moved, consumer offsets started going
to a different partition of the offsets topic.
However, the previous partition of the offsets topic can still have
the old offsets. Those won't necessarily
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212873#comment-14212873
]
Joel Koshy commented on KAFKA-1481:
---
[~junrao] For 80.2, I believe the additional
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27693/#review61515
---
core/src/main/scala/kafka/tools/ConsumerCommand.scala
[
https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212953#comment-14212953
]
Guozhang Wang commented on KAFKA-1624:
--
I did some tests locally with various Scala
[
https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1642:
---
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the patch. Committed to trunk.
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14212987#comment-14212987
]
Jun Rao commented on KAFKA-1481:
[~jjkoshy], yes, re-registering an existing mbean is a
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27536/
---
(Updated Nov. 14, 2014, 10:54 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213013#comment-14213013
]
Jun Rao commented on KAFKA-1642:
Since this is relatively critical and the changes are
[
https://issues.apache.org/jira/browse/KAFKA-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213012#comment-14213012
]
Ewen Cheslack-Postava commented on KAFKA-1748:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1748:
-
Attachment: KAFKA-1748_2014-11-14_14:54:17.patch
Decouple system test cluster
[
https://issues.apache.org/jira/browse/KAFKA-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213021#comment-14213021
]
Ewen Cheslack-Postava commented on KAFKA-1748:
--
A couple of improvements to
[
https://issues.apache.org/jira/browse/KAFKA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213052#comment-14213052
]
Jun Rao commented on KAFKA-948:
---
Currently, if you want to replace a failed broker, you will
[
https://issues.apache.org/jira/browse/KAFKA-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1721:
---
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the patch. Since this change is
We have a metric that measures the per-topic bytes send rate (after
compression). You can get the values through the producer api.
Thanks,
Jun
On Fri, Nov 14, 2014 at 10:34 AM, Bhavesh Mistry mistry.p.bhav...@gmail.com
wrote:
HI Kafka Team,
We like to enforce a network bandwidth quota
[
https://issues.apache.org/jira/browse/KAFKA-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213141#comment-14213141
]
Jun Rao commented on KAFKA-1767:
Do you have an easy way to reproduce this on trunk?
[
https://issues.apache.org/jira/browse/KAFKA-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213173#comment-14213173
]
Guozhang Wang commented on KAFKA-1767:
--
Do you have a controller migration before
Hi,
Is the Simple Consumer API will change in Kafka 0.9 ?
I can see a Consumer Re-design approach for Kafka 0.9 , which I believe
will not impact any client written using Simple Consumer API . Is that
correct ?
Regards,
Dibyendu
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27634/#review61581
---
Thanks for the patch. Looks good overall. A few comments below.
[
https://issues.apache.org/jira/browse/KAFKA-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1766.
Resolution: Fixed
Fix Version/s: 0.8.2
Thanks for pointing this out. Fix the site.
Ecosystem docs
[
https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213272#comment-14213272
]
Jun Rao commented on KAFKA-493:
---
[~activars], how do I look at the snapshot? Could you
[
https://issues.apache.org/jira/browse/KAFKA-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213284#comment-14213284
]
Jun Rao commented on KAFKA-1757:
Thanks for the patch. It's not clear to me if this really
[
https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein reopened KAFKA-1751:
--
handle broker not exists and topic not exists scenarios
[
https://issues.apache.org/jira/browse/KAFKA-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1751:
-
Status: Patch Available (was: Reopened)
handle broker not exists and topic not exists scenarios
Joe Stein created KAFKA-1772:
Summary: Add an Admin message type for request response
Key: KAFKA-1772
URL: https://issues.apache.org/jira/browse/KAFKA-1772
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213409#comment-14213409
]
Otis Gospodnetic commented on KAFKA-1481:
-
bq. 80.4 We will need to add the same
79 matches
Mail list logo
