[jira] [Commented] (KAFKA-2245) Add response tests for ConsumerCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594429#comment-14594429 ] Onur Karaman commented on KAFKA-2245: - The original patch resulted in ReplicaManagerTe

Re: Review Request 35086: add response tests for ConsumerCoordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35086/ --- (Updated June 20, 2015, 6:10 a.m.) Review request for kafka. Bugs: KAFKA-2245

Re: Review Request 35086: add response tests for ConsumerCoordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35086/#review88630 --- Various tests under ReplicaManagerTest were failing only during batc

Re: Review Request 35086: add response tests for ConsumerCoordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35086/#review88629 --- Ship it! Ship It! - Joel Koshy On June 20, 2015, 5:56 a.m., Onur

[jira] [Updated] (KAFKA-2245) Add response tests for ConsumerCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-2245: Attachment: KAFKA-2245_2015-06-19_22:55:56.patch > Add response tests for ConsumerCoordinator >

[jira] [Commented] (KAFKA-2245) Add response tests for ConsumerCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594421#comment-14594421 ] Onur Karaman commented on KAFKA-2245: - Updated reviewboard https://reviews.apache.org/

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594420#comment-14594420 ] Manikumar Reddy commented on KAFKA-2012: I am not sure if we can find out the reas

Re: Review Request 35086: add response tests for ConsumerCoordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35086/ --- (Updated June 20, 2015, 5:56 a.m.) Review request for kafka. Bugs: KAFKA-2245

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

My initial thoughts: Although it is kind of discussed very broadly, I did struggle a bit to properly grasp the value add this adds over the alternative approaches that are available today (or need a little work to accomplish) in specific use cases. I feel its better to take specific common use

[jira] [Updated] (KAFKA-2288) Follow-up to KAFKA-2249 - reduce logging and testing

[ https://issues.apache.org/jira/browse/KAFKA-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2288: Attachment: KAFKA-2288.patch > Follow-up to KAFKA-2249 - reduce logging and testing > --

[jira] [Updated] (KAFKA-2288) Follow-up to KAFKA-2249 - reduce logging and testing

[ https://issues.apache.org/jira/browse/KAFKA-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2288: Status: Patch Available (was: Open) > Follow-up to KAFKA-2249 - reduce logging and testing > --

[jira] [Commented] (KAFKA-2288) Follow-up to KAFKA-2249 - reduce logging and testing

[ https://issues.apache.org/jira/browse/KAFKA-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594222#comment-14594222 ] Gwen Shapira commented on KAFKA-2288: - Created reviewboard https://reviews.apache.org/

Review Request 35677: Patch for KAFKA-2288

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35677/ --- Review request for kafka. Bugs: KAFKA-2288 https://issues.apache.org/jira/b

[jira] [Created] (KAFKA-2291) Documentation Error

UTKARSH BHATNAGAR created KAFKA-2291: Summary: Documentation Error Key: KAFKA-2291 URL: https://issues.apache.org/jira/browse/KAFKA-2291 Project: Kafka Issue Type: Bug Component

[jira] [Created] (KAFKA-2290) OffsetIndex should open RandomAccessFile consistently

Jun Rao created KAFKA-2290: -- Summary: OffsetIndex should open RandomAccessFile consistently Key: KAFKA-2290 URL: https://issues.apache.org/jira/browse/KAFKA-2290 Project: Kafka Issue Type: Bug

Build failed in Jenkins: Kafka-trunk #515

See Changes: [junrao] kafka-2265; creating a topic with large number of partitions takes a long time; patched by Manikumar Reddy; reviewed by Jun Rao [junrao] kafka-2234; Partition reassignment of a nonexistent topic prevents future reass

[jira] [Commented] (KAFKA-2289) KafkaProducer logs erroneous warning on startup

[ https://issues.apache.org/jira/browse/KAFKA-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594087#comment-14594087 ] ASF GitHub Bot commented on KAFKA-2289: --- GitHub user hgschmie opened a pull request:

[jira] [Commented] (KAFKA-2289) KafkaProducer logs erroneous warning on startup

[ https://issues.apache.org/jira/browse/KAFKA-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594089#comment-14594089 ] Henning Schmiedehausen commented on KAFKA-2289: --- Pull request with a fix is

[GitHub] kafka pull request: KAFKA-2289: KafkaProducer logs erroneous warni...

GitHub user hgschmie opened a pull request: https://github.com/apache/kafka/pull/71 KAFKA-2289: KafkaProducer logs erroneous warning on startup This change fixes the problem. You can merge this pull request into a Git repository by running: $ git pull https://github.com/hgschmi

[jira] [Updated] (KAFKA-2289) KafkaProducer logs erroneous warning on startup

[ https://issues.apache.org/jira/browse/KAFKA-2289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Schmiedehausen updated KAFKA-2289: -- Summary: KafkaProducer logs erroneous warning on startup (was: KafkaProducer lo

[jira] [Created] (KAFKA-2289) KafkaProducer logs erroneous warning on startu.

Henning Schmiedehausen created KAFKA-2289: - Summary: KafkaProducer logs erroneous warning on startu. Key: KAFKA-2289 URL: https://issues.apache.org/jira/browse/KAFKA-2289 Project: Kafka

Build failed in Jenkins: KafkaPreCommit #127

See Changes: [junrao] kafka-2234; Partition reassignment of a nonexistent topic prevents future reassignments; patched by Manikumar Reddy; reviewed by Jun Rao [junrao] trivial change to fix unit test failure introduced in kafka-2234 [j

[jira] [Resolved] (KAFKA-2286) Cannot produce messages remotely: No partition metadata for topic test due to kafka.common.LeaderNotAvailableException

[ https://issues.apache.org/jira/browse/KAFKA-2286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Bridge resolved KAFKA-2286. Resolution: Not A Problem Fix Version/s: 0.8.1.2 This turns out to be a problem with my confi

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

I think we want the connectors to be federated just because trying to maintain all the connectors centrally would be really painful. I think if we really do this well we would want to have >100 of these connectors so it really won't make sense to maintain them with the project. I think the thought

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

I think BikeShed will be a great name. Can you clarify the scope? The KIP discusses a framework and also few examples for connectors. Does the addition include just the framework (and perhaps an example or two), or do we plan to start accepting connectors to Apache Kafka project? Gwen On Thu, Ju

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593953#comment-14593953 ] Jun Rao commented on KAFKA-2012: I am not sure if it's better to add another config. Perha

[jira] [Assigned] (KAFKA-2288) Follow-up to KAFKA-2249 - reduce logging and testing

[ https://issues.apache.org/jira/browse/KAFKA-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira reassigned KAFKA-2288: --- Assignee: Gwen Shapira > Follow-up to KAFKA-2249 - reduce logging and testing > -

[jira] [Created] (KAFKA-2288) Follow-up to KAFKA-2249 - reduce logging and testing

Gwen Shapira created KAFKA-2288: --- Summary: Follow-up to KAFKA-2249 - reduce logging and testing Key: KAFKA-2288 URL: https://issues.apache.org/jira/browse/KAFKA-2288 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593812#comment-14593812 ] Mayuresh Gharat edited comment on KAFKA-2012 at 6/19/15 7:30 PM: ---

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593812#comment-14593812 ] Mayuresh Gharat commented on KAFKA-2012: Discussed this with [~jjkoshy]. This patc

[jira] [Created] (KAFKA-2287) Add metric to track the number of clientId throttled

Aditya Auradkar created KAFKA-2287: -- Summary: Add metric to track the number of clientId throttled Key: KAFKA-2287 URL: https://issues.apache.org/jira/browse/KAFKA-2287 Project: Kafka Issue

[jira] [Commented] (KAFKA-2271) transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps

[ https://issues.apache.org/jira/browse/KAFKA-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593646#comment-14593646 ] Jason Gustafson commented on KAFKA-2271: This patch may or may not fix the problem

[jira] [Updated] (KAFKA-2271) transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps

[ https://issues.apache.org/jira/browse/KAFKA-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2271: --- Assignee: Jason Gustafson Status: Patch Available (was: Open) > transient unit test fai

[jira] [Updated] (KAFKA-2271) transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps

[ https://issues.apache.org/jira/browse/KAFKA-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2271: --- Attachment: KAFKA-2271.patch > transient unit test failure in KafkaConfigConfigDefTest.testFro

Review Request 35655: Patch for KAFKA-2271

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35655/ --- Review request for kafka. Bugs: KAFKA-2271 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-2271) transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps

[ https://issues.apache.org/jira/browse/KAFKA-2271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593622#comment-14593622 ] Jason Gustafson commented on KAFKA-2271: Created reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2012: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

[jira] [Commented] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593585#comment-14593585 ] Jun Rao commented on KAFKA-2249: Yes, fixing it in another jira is fine. Thanks. > KafkaC

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2168: --- Attachment: KAFKA-2168_2015-06-19_09:19:02.patch > New consumer poll() can block other calls l

[jira] [Commented] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593579#comment-14593579 ] Jason Gustafson commented on KAFKA-2168: Updated reviewboard https://reviews.apach

Re: Review Request 34789: Patch for KAFKA-2168

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34789/ --- (Updated June 19, 2015, 4:19 p.m.) Review request for kafka. Bugs: KAFKA-2168

[jira] [Commented] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593555#comment-14593555 ] Gwen Shapira commented on KAFKA-2249: - Agree that the test is kinda silly now :) And

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2012: --- Attachment: KAFKA-2012_2015-06-19_21:09:22.patch > Broker should automatically handle corrupt

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593535#comment-14593535 ] Manikumar Reddy commented on KAFKA-2012: Updated reviewboard https://reviews.apach

Re: Review Request 35503: Patch for KAFKA-2012

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35503/ --- (Updated June 19, 2015, 3:42 p.m.) Review request for kafka. Bugs: KAFKA-2012

[jira] [Commented] (KAFKA-1451) Broker stuck due to leader election race

[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593515#comment-14593515 ] Raghav commented on KAFKA-1451: --- Hit this issue on version 0.8.2.1 when twiiterstream genera

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593496#comment-14593496 ] Jun Rao commented on KAFKA-2012: The latest patch looks good to me. Could you rebase since

[jira] [Resolved] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1646. Resolution: Fixed Fix Version/s: 0.8.3 Assignee: Honghai Chen (was: xueqiang wang) Thanks f

[jira] [Commented] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593469#comment-14593469 ] Jun Rao commented on KAFKA-2249: Also, I am not sure if LogConfigTest.testFromPropsToProps

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2012: --- Status: Patch Available (was: In Progress) > Broker should automatically handle corrupt index

Re: Review Request 35503: Patch for KAFKA-2012

> On June 19, 2015, 12:11 a.m., Jun Rao wrote: > > core/src/main/scala/kafka/log/Log.scala, lines 225-227 > > > > > > Do we still need this now that we have verified the index consistency > > earlier? Yes, we can rem

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2012: --- Attachment: KAFKA-2012_2015-06-19_18:55:11.patch > Broker should automatically handle corrupt

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593418#comment-14593418 ] Manikumar Reddy commented on KAFKA-2012: Updated reviewboard https://reviews.apach

Re: Review Request 35503: Patch for KAFKA-2012

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35503/ --- (Updated June 19, 2015, 1:27 p.m.) Review request for kafka. Bugs: KAFKA-2012

[jira] [Resolved] (KAFKA-1656) "replica-assignment" option in "bin/kakfa-topics.sh" doesn't work with "alter"

[ https://issues.apache.org/jira/browse/KAFKA-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1656. Resolution: Duplicate This got fixed in KAFKA-1947 > "replica-assignment" option in "bin/k

[jira] [Commented] (KAFKA-2283) scheduler exception on non-controller node when shutdown

[ https://issues.apache.org/jira/browse/KAFKA-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593154#comment-14593154 ] Manikumar Reddy commented on KAFKA-2283: looks like this got fixed in trunk build