Olof Johansson created KAFKA-2273:
-
Summary: Add rebalance with a minimal number of reassignments to
server-defined strategy list
Key: KAFKA-2273
URL: https://issues.apache.org/jira/browse/KAFKA-2273
[
https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Olof Johansson updated KAFKA-2273:
--
Reviewer: Guozhang Wang
Add rebalance with a minimal number of reassignments to server-defined
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588083#comment-14588083
]
Sayat Satybaldiyev edited comment on KAFKA-2078 at 6/16/15 2:15 PM:
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588195#comment-14588195
]
Sayat Satybaldiyev commented on KAFKA-2078:
---
I made a bench one more time and
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2270:
---
Assignee: Proneet Verma
incorrect package name in unit tests
Congrats Guozhang!
From: Ashish Singh [asi...@cloudera.com]
Sent: Monday, June 15, 2015 10:53 PM
To: dev@kafka.apache.org
Cc: Jun Rao
Subject: Re: Guozhang Wang elected to Kafka PMC
Congrats Guozhang!
On Mon, Jun 15, 2015 at 10:20 PM, Sriharsha
On June 15, 2015, 6:09 p.m., Jun Rao wrote:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java,
line 1199
https://reviews.apache.org/r/34789/diff/9/?file=983137#file983137line1199
Doesn't this cause poll() to block for the backoff time?
Generally it
Added.
Thanks,
Jun
On Tue, Jun 16, 2015 at 3:07 AM, Proneet Verma pronee...@gmail.com wrote:
Hi,
I am a junior undergrad from India, where I am currently working on
developing streaming apps with kafka and spark. After working with it for a
while, I fell I'd love to contribute to the
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588109#comment-14588109
]
Jun Rao commented on KAFKA-2270:
Thanks for the patch. Got a bunch of compilation errors
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35524/
---
Review request for kafka.
Bugs: KAFKA-2092
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34415/#review88074
---
Thanks for the latest patch. A couple more minor comments.
[
https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588170#comment-14588170
]
Jun Rao commented on KAFKA-1646:
[~waldenchen], thanks for the latest patch. A couple of
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proneet Verma updated KAFKA-2270:
-
Attachment: fix-kafka-2270-v2.patch
I compiled 'unit.kafka'. Gave no errors with this patch.
Let
[
https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-2254:
-
Fix Version/s: (was: 0.8.2.1)
0.8.3
The shell script should be optimized , even
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35454/#review88106
---
core/src/main/scala/kafka/server/KafkaConfig.scala (line 242)
Thank you folks! Very glad to be onboard to PMC.
Guozhang
On Tue, Jun 16, 2015 at 9:59 AM, Dong Lin lindon...@gmail.com wrote:
Congrats Guozhang!
Dong
On Tue, Jun 16, 2015 at 9:57 AM, Timothy Chen tnac...@gmail.com wrote:
Congrats Guozhang!!
Tim
On Tue, Jun 16, 2015 at 8:19 AM,
Congrats Guozhang!
Thanks for your contributions :)
On Mon, Jun 15, 2015 at 9:59 PM, Jun Rao j...@confluent.io wrote:
Hi, Everyone,
Guozhang Wang has been active in the Kafka community since he became a
Kafka committer about 7 months ago. I am glad to announce that Guozhang is
now a member
[
https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588522#comment-14588522
]
Joel Koshy commented on KAFKA-2159:
---
Yes.
offsets.topic.segment.bytes and
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proneet Verma updated KAFKA-2270:
-
Attachment: fix-kafka-2270.patch
incorrect package name in unit tests
[
https://issues.apache.org/jira/browse/KAFKA-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1000.
--
Resolution: Fixed
Inbuilt consumer offset management feature for kakfa
[
https://issues.apache.org/jira/browse/KAFKA-2207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-2207:
-
Fix Version/s: (was: 0.8.2.1)
0.8.3
The testCannotSendToInternalTopic test method
[
https://issues.apache.org/jira/browse/KAFKA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588420#comment-14588420
]
Jay Kreps commented on KAFKA-2092:
--
Hmm, not sure if I follow this. My understanding of
[
https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1326:
-
Fix Version/s: 0.8.3
New consumer checklist
--
Key: KAFKA-1326
[
https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pakulov reassigned KAFKA-1782:
Assignee: Alexander Pakulov (was: Jeff Holoman)
Junit3 Misusage
---
Congrats Guozhang!
Dong
On Tue, Jun 16, 2015 at 9:57 AM, Timothy Chen tnac...@gmail.com wrote:
Congrats Guozhang!!
Tim
On Tue, Jun 16, 2015 at 8:19 AM, Aditya Auradkar
aaurad...@linkedin.com.invalid wrote:
Congrats Guozhang!
From: Ashish
[
https://issues.apache.org/jira/browse/KAFKA-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2045:
-
Component/s: consumer
Memory Management on the consumer
-
[
https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-2195.
Resolution: Fixed
Thanks for the latest patch. +1 and committed to trunk.
Add versionId to
[
https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-2195:
--
Assignee: Andrii Biletskyi (was: Jun Rao)
Add versionId to AbstractRequest.getErrorResponse and
Jiangjie Qin created KAFKA-2277:
---
Summary: New producer treats requests to a disconnected broker as
acks=0.
Key: KAFKA-2277
URL: https://issues.apache.org/jira/browse/KAFKA-2277
Project: Kafka
The following are my notes for today's call.
KIP-12: SSL patch is still in progress.
KIP-23: Agreed to deprecate the old ConsumerOffsetChecker.
new consumer: Guozhang will mark sub-tasks intended for 0.8.3 in KAFKA-1326.
Thanks,
Jun
On Mon, Jun 15, 2015 at 3:16 PM, Jun Rao j...@confluent.io
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proneet Verma updated KAFKA-2270:
-
Attachment: (was: fix-kafka-2270-v2.patch)
incorrect package name in unit tests
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proneet Verma updated KAFKA-2270:
-
Attachment: (was: fix-kafka-2270.patch)
incorrect package name in unit tests
[
https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-2159:
--
Reviewer: Joel Koshy
offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588313#comment-14588313
]
Proneet Verma edited comment on KAFKA-2270 at 6/16/15 6:41 PM:
Dong Lin created KAFKA-2278:
---
Summary: JmxTool should support querying all objects when
object-name is omitted
Key: KAFKA-2278
URL: https://issues.apache.org/jira/browse/KAFKA-2278
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2272:
---
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
Thanks for
[
https://issues.apache.org/jira/browse/KAFKA-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-2277.
-
Resolution: Not A Problem
Never mind...
New producer treats requests to a disconnected broker
GitHub user granders opened a pull request:
https://github.com/apache/kafka/pull/70
Kafka 2276
Initial patch for KIP-25
Note that to install ducktape, do *not* use pip to install ducktape.
Instead:
```
$ git clone g...@github.com:confluentinc/ducktape.git
As we have discussed in today's KIP, here is the list of tasks that is left
before we can cut the first release of new consumer (and hence 0.8.3):
project = KAFKA AND resolution = Unresolved AND fixVersion = 0.8.3 AND
component = consumer
in
https://issues.apache.org/jira/issues/?jql=
There
[
https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2278:
Status: Patch Available (was: Open)
JmxTool should support querying all objects when object-name is
[
https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2278:
Attachment: KAFKA-2278.patch
JmxTool should support querying all objects when object-name is omitted
[
https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588865#comment-14588865
]
Dong Lin commented on KAFKA-2278:
-
Created reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35540/
---
Review request for kafka.
Bugs: KAFKA-2278
[
https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-2270.
Resolution: Fixed
Thanks for the patch. +1. Committed to trunk after removing {} on single class
imports.
[
https://issues.apache.org/jira/browse/KAFKA-1329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1329:
-
Fix Version/s: 0.8.3
Add metadata fetch and refresh functionality to the consumer
[
https://issues.apache.org/jira/browse/KAFKA-1331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1331:
-
Affects Version/s: (was: 0.9.0)
Add ability to commit offsets to the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1331:
-
Fix Version/s: 0.8.3
Add ability to commit offsets to the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1331:
-
Assignee: Jay Kreps
Add ability to commit offsets to the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1330:
-
Affects Version/s: (was: 0.9.0)
Implement subscribe(TopicPartition...partitions) and
Geoffrey Anderson created KAFKA-2276:
Summary: Initial patch for KIP-25
Key: KAFKA-2276
URL: https://issues.apache.org/jira/browse/KAFKA-2276
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588607#comment-14588607
]
Andrii Biletskyi commented on KAFKA-2195:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1335:
-
Fix Version/s: 0.8.3
Add rebalancing logic to the coordinator / consumer
[
https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1333:
-
Fix Version/s: 0.8.3
Add consumer co-ordinator module to the server
[
https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1330:
-
Fix Version/s: 0.8.3
Implement subscribe(TopicPartition...partitions) and pool(timeout) in the
[
https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2123:
-
Issue Type: Sub-task (was: Improvement)
Parent: KAFKA-1326
Make new consumer offset
[
https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2123:
-
Priority: Critical (was: Major)
Make new consumer offset commit API use callback + future
Guozhang Wang created KAFKA-2275:
Summary: Add a ListTopic() API to the new consumer
Key: KAFKA-2275
URL: https://issues.apache.org/jira/browse/KAFKA-2275
Project: Kafka
Issue Type: Sub-task
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34415/
---
(Updated June 16, 2015, 7:28 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrii Biletskyi updated KAFKA-2195:
Attachment: KAFKA-2195_2015-06-16_22:28:19.patch
Add versionId to
[
https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1328:
-
Affects Version/s: (was: 0.8.1)
(was: 0.8.0)
Add new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1316:
-
Fix Version/s: (was: 0.8.2.0)
0.8.3
Refactor Sender
---
[
https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1328:
-
Fix Version/s: (was: 0.8.2.0)
0.8.3
Add new consumer APIs
[
https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1740:
-
Fix Version/s: (was: 0.9.0)
0.8.3
Merge Offset manager into Coordinator
[
https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2168:
-
Fix Version/s: 0.8.3
New consumer poll() can block other calls like position(), commit(), and
[
https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2168:
-
Issue Type: Sub-task (was: Bug)
Parent: KAFKA-1326
New consumer poll() can block other
[
https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2168:
-
Priority: Critical (was: Major)
New consumer poll() can block other calls like position(),
[
https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2273:
-
Labels: newbie++ (was: )
Add rebalance with a minimal number of reassignments to server-defined
[
https://issues.apache.org/jira/browse/KAFKA-1895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1895:
-
Fix Version/s: 0.9.0
Investigate moving deserialization and decompression out of KafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2239:
-
Fix Version/s: 0.9.0
Allow coordinator to aggresively remove group when it is no longer owning
[
https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2273:
-
Assignee: (was: Neha Narkhede)
Add rebalance with a minimal number of reassignments to
[
https://issues.apache.org/jira/browse/KAFKA-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1334:
-
Fix Version/s: 0.8.3
Coordinator should detect consumer failures
[
https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1740:
-
Priority: Critical (was: Major)
Merge Offset manager into Coordinator
[
https://issues.apache.org/jira/browse/KAFKA-1332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1332:
-
Fix Version/s: 0.9.0
Add functionality to the offsetsBeforeTime() API
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1893:
-
Fix Version/s: 0.8.3
Allow regex subscriptions in the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1893:
-
Priority: Critical (was: Major)
Allow regex subscriptions in the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1894:
-
Fix Version/s: 0.9.0
Avoid long or infinite blocking in the consumer
[
https://issues.apache.org/jira/browse/KAFKA-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2245:
-
Fix Version/s: 0.8.3
Add response tests for ConsumerCoordinator
On June 16, 2015, 3:52 p.m., Jun Rao wrote:
clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java,
lines 49-50
https://reviews.apache.org/r/34415/diff/3/?file=984580#file984580line49
Perhaps it's better to include the request name in the error
[
https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2273:
-
Fix Version/s: 0.9.0
Add rebalance with a minimal number of reassignments to server-defined
[
https://issues.apache.org/jira/browse/KAFKA-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2017:
-
Fix Version/s: 0.9.0
Persist Coordinator State for Coordinator Failover
Guozhang Wang created KAFKA-2274:
Summary: Add integration test for consumer coordinator
Key: KAFKA-2274
URL: https://issues.apache.org/jira/browse/KAFKA-2274
Project: Kafka
Issue Type:
See https://builds.apache.org/job/Kafka-trunk/512/changes
Changes:
[junrao] kafka-2195; Add versionId to AbstractRequest.getErrorResponse and
AbstractRequest.getRequest; patched by Andrii Biletskyi; reviewed by Jun Rao
[junrao] kafka-2270; incorrect package name in unit tests; patched by
[
https://issues.apache.org/jira/browse/KAFKA-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2235:
---
Reviewer: Jun Rao (was: Jay Kreps)
Status: In Progress (was: Patch Available)
Thanks for the patch.
See https://builds.apache.org/job/KafkaPreCommit/124/changes
Changes:
[junrao] kafka-2195; Add versionId to AbstractRequest.getErrorResponse and
AbstractRequest.getRequest; patched by Andrii Biletskyi; reviewed by Jun Rao
[junrao] kafka-2270; incorrect package name in unit tests; patched by
[
https://issues.apache.org/jira/browse/KAFKA-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2264:
---
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
Thanks for
[
https://issues.apache.org/jira/browse/KAFKA-2262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2262:
---
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
Thanks for
Jun Rao created KAFKA-2279:
--
Summary: add a main method in LogConfig to generate topic level
configs in html
Key: KAFKA-2279
URL: https://issues.apache.org/jira/browse/KAFKA-2279
Project: Kafka
Dong Lin created KAFKA-2280:
---
Summary: Measurement of bytesInRate and bytesOutRate in
BrokerTopicMetrics should be consistent
Key: KAFKA-2280
URL: https://issues.apache.org/jira/browse/KAFKA-2280
Project:
Oops, linked the wrong thing. Here's the correct one:
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=58851767
-Ewen
On Tue, Jun 16, 2015 at 4:32 PM, Ewen Cheslack-Postava e...@confluent.io
wrote:
Hi all,
I just posted KIP-26 - Add Copycat, a connector framework for data
Hi all,
I just posted KIP-26 - Add Copycat, a connector framework for data
import/export here:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals
This is a large KIP compared to what we've had so far, and is a bit
different from most. We're proposing the addition of a
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34805/#review88148
---
Thanks for the patch.
See https://builds.apache.org/job/KafkaPreCommit/125/changes
Hi,
While testing message delivery using kafka, I realized that few duplicate
messages got delivered by the consumers in the same consumer group (two
consumers got the same message with few milli-seconds difference). However,
I do not see any redundancy at the producer or broker. One more
[
https://issues.apache.org/jira/browse/KAFKA-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589206#comment-14589206
]
Patrick Lucas commented on KAFKA-2255:
--
+1, documentation for this option would be
[
https://issues.apache.org/jira/browse/KAFKA-369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14589225#comment-14589225
]
Jiahongchao commented on KAFKA-369:
---
So In producer we need a metadata.broker.list:
Hey Ewen, very interesting!
I like the idea of the connector and making one side always being Kafka for
all the reasons you mentioned. It makes having to build consumers (over and
over and over (and over)) again for these type of tasks much more
consistent for everyone.
Some initial comments
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35493/
---
Review request for kafka.
Bugs: KAFKA-1646
[
https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14587601#comment-14587601
]
Honghai Chen commented on KAFKA-1646:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Honghai Chen updated KAFKA-1646:
Attachment: KAFKA-1646_20150616_FixFormat.patch
Improve consumer read performance for Windows
1 - 100 of 109 matches
Mail list logo
