[jira] [Updated] (KAFKA-6151) kafka broker not starting ; WARN kafka.log.Log: Found a corrupted index file

2017-10-30 Thread Prince Paulson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prince Paulson updated KAFKA-6151: -- Description: {code}

[jira] [Created] (KAFKA-6151) kafka broker not starting ; WARN kafka.log.Log: Found a corrupted index file

2017-10-30 Thread Prince Paulson (JIRA)
Prince Paulson created KAFKA-6151: - Summary: kafka broker not starting ; WARN kafka.log.Log: Found a corrupted index file Key: KAFKA-6151 URL: https://issues.apache.org/jira/browse/KAFKA-6151

[jira] [Commented] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

2017-10-30 Thread Simon Wan Wenli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16226284#comment-16226284 ] Simon Wan Wenli commented on KAFKA-4083: Is this patch still necessary? If so, I can resolve its

[jira] [Commented] (KAFKA-4083) ReassignPartitionsCommand does not check replication factor

2017-10-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16226194#comment-16226194 ] Ewen Cheslack-Postava commented on KAFKA-4083: -- Presumably it is

[jira] [Commented] (KAFKA-6147) Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException

2017-10-30 Thread Sandro Simas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16226119#comment-16226119 ] Sandro Simas commented on KAFKA-6147: - OK, I found the problem. My process was starting another

[jira] [Commented] (KAFKA-6150) Make Repartition Topics Transient

2017-10-30 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16226082#comment-16226082 ] Guozhang Wang commented on KAFKA-6150: -- A couple of issues to consider here: 1. Restoration:

[jira] [Created] (KAFKA-6150) Make Repartition Topics Transient

2017-10-30 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6150: Summary: Make Repartition Topics Transient Key: KAFKA-6150 URL: https://issues.apache.org/jira/browse/KAFKA-6150 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

2017-10-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16226013#comment-16226013 ] Jun Rao commented on KAFKA-4084: [~jeffwidman], the detailed perf results can be found in

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

2017-10-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16226007#comment-16226007 ] Matthias J. Sax commented on KAFKA-6144: [~astubbs] Is this a duplicate of KAFKA-6031 ? > Allow

[jira] [Updated] (KAFKA-6147) Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException

2017-10-30 Thread Sandro Simas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandro Simas updated KAFKA-6147: Description: I'm getting the following error on my kafka client 0.11.0.1: {code:java} [2017-10-30

[jira] [Updated] (KAFKA-6147) Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException

2017-10-30 Thread Sandro Simas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandro Simas updated KAFKA-6147: Description: I'm getting the following error on my kafka client 0.11.0.1: {code:java} [2017-10-30

[jira] [Created] (KAFKA-6149) LogCleanerManager should include topic partition name when warning of invalid cleaner offset

2017-10-30 Thread Ryan P (JIRA)
Ryan P created KAFKA-6149: - Summary: LogCleanerManager should include topic partition name when warning of invalid cleaner offset Key: KAFKA-6149 URL: https://issues.apache.org/jira/browse/KAFKA-6149

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

2017-10-30 Thread Jeff Widman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225870#comment-16225870 ] Jeff Widman commented on KAFKA-4084: [~junrao] any ballpark quantification to "much faster"? Are we

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225833#comment-16225833 ] ASF GitHub Bot commented on KAFKA-4499: --- GitHub user ConcurrencyPractitioner opened a pull request:

[jira] [Created] (KAFKA-6148) ERROR Commit of WorkerSinkTask{id=bigquery-connector-log-0} offsets threw an unexpected exception: (org.apache.kafka.connect.runtime.WorkerSinkTask:205) java.lang.ClassC

2017-10-30 Thread Eugene Burd (JIRA)
Eugene Burd created KAFKA-6148: -- Summary: ERROR Commit of WorkerSinkTask{id=bigquery-connector-log-0} offsets threw an unexpected exception: (org.apache.kafka.connect.runtime.WorkerSinkTask:205) java.lang.ClassCastException:

[jira] [Resolved] (KAFKA-6139) error when loading plugins

2017-10-30 Thread Eugene Burd (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Burd resolved KAFKA-6139. Resolution: Information Provided Error was due to having the plugin directory set a level too low

[jira] [Updated] (KAFKA-6147) Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException

2017-10-30 Thread Sandro Simas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandro Simas updated KAFKA-6147: Description: I'm getting the following error on my kafka client 0.11.0.1: {code:java} [2017-10-30

[jira] [Updated] (KAFKA-5647) Use async ZookeeperClient for Admin operations

2017-10-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-5647: --- Description: Since we will be removing the ZK dependency in most of the admin clients, we only need to change

[jira] [Updated] (KAFKA-5647) Use async ZookeeperClient for Admin operations

2017-10-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-5647: --- Description: Since we will be removing the ZK dependency in most of the admin clients, we only need to change

[jira] [Comment Edited] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

2017-10-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225767#comment-16225767 ] Jun Rao edited comment on KAFKA-4084 at 10/30/17 9:30 PM: -- The auto leader

[jira] [Resolved] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

2017-10-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-4084. Resolution: Fixed Fix Version/s: 1.1.0 The auto leader balancing logic now uses the async ZK api and

[jira] [Assigned] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

2017-10-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-3018: -- Assignee: (was: Jun Rao) > Kafka producer hangs on producer.close() call if the producer topic

[jira] [Updated] (KAFKA-6147) Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException

2017-10-30 Thread Sandro Simas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandro Simas updated KAFKA-6147: Description: I'm getting the following error on my kafka client 0.11.0.1: {code:java} [2017-10-30

[jira] [Updated] (KAFKA-6147) Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException

2017-10-30 Thread Sandro Simas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandro Simas updated KAFKA-6147: Description: I'm getting the following error on my kafka client 0.11.0.1: {code:java} [2017-10-30

[jira] [Created] (KAFKA-6147) Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException

2017-10-30 Thread Sandro Simas (JIRA)
Sandro Simas created KAFKA-6147: --- Summary: Error reading field 'api_versions': Error reading field 'max_version': java.nio.BufferUnderflowException Key: KAFKA-6147 URL:

[jira] [Commented] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225514#comment-16225514 ] ASF GitHub Bot commented on KAFKA-5212: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-10-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5212. Resolution: Fixed Fix Version/s: (was: 1.0.1) Issue resolved by pull request

[jira] [Commented] (KAFKA-2903) FileRecords.read doesn't handle size > sizeInBytes when start is not zero

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225460#comment-16225460 ] ASF GitHub Bot commented on KAFKA-2903: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-6146) re-register the exist watch on PreferredReplicaElectionZNode after the preferred leader election completes

2017-10-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225449#comment-16225449 ] Jun Rao commented on KAFKA-6146: We can fix this in a way similar to

[jira] [Updated] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

2017-10-30 Thread Antony Stubbs (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6145: - Description: Currently when expanding the KS cluster, the new node's partitions will be

[jira] [Updated] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

2017-10-30 Thread Antony Stubbs (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Antony Stubbs updated KAFKA-6144: - Description: Currently when expanding the KS cluster, the new node's partitions will be

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

2017-10-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225395#comment-16225395 ] Ted Yu commented on KAFKA-6144: --- Please prepare a KIP. > Allow state stores to serve stale reads during

[jira] [Created] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

2017-10-30 Thread Antony Stubbs (JIRA)
Antony Stubbs created KAFKA-6145: Summary: Warm up new KS instances before migrating tasks - potentially a two phase rebalance Key: KAFKA-6145 URL: https://issues.apache.org/jira/browse/KAFKA-6145

[jira] [Created] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

2017-10-30 Thread Antony Stubbs (JIRA)
Antony Stubbs created KAFKA-6144: Summary: Allow state stores to serve stale reads during rebalance Key: KAFKA-6144 URL: https://issues.apache.org/jira/browse/KAFKA-6144 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6130) VerifiableConsumer with --max-messages doesn't exit

2017-10-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6130. Resolution: Fixed Fix Version/s: 1.1.0 > VerifiableConsumer with --max-messages

[jira] [Commented] (KAFKA-6130) VerifiableConsumer with --max-messages doesn't exit

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225313#comment-16225313 ] ASF GitHub Bot commented on KAFKA-6130: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-6073) Use ZookeeperClient in KafkaApis

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225292#comment-16225292 ] ASF GitHub Bot commented on KAFKA-6073: --- Github user asfgit closed the pull request at:

[jira] [Created] (KAFKA-6143) VerifiableProducer & VerifiableConsumer need tests

2017-10-30 Thread Tom Bentley (JIRA)
Tom Bentley created KAFKA-6143: -- Summary: VerifiableProducer & VerifiableConsumer need tests Key: KAFKA-6143 URL: https://issues.apache.org/jira/browse/KAFKA-6143 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6142) Connect worker configurations and connector configurations should accept environment variables

2017-10-30 Thread Randall Hauch (JIRA)
Randall Hauch created KAFKA-6142: Summary: Connect worker configurations and connector configurations should accept environment variables Key: KAFKA-6142 URL: https://issues.apache.org/jira/browse/KAFKA-6142

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-30 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225159#comment-16225159 ] Ben Corlett commented on KAFKA-6042: The new build was installed 14:10ish on the 23rd. It was

[jira] [Comment Edited] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-30 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225144#comment-16225144 ] Ben Corlett edited comment on KAFKA-6042 at 10/30/17 3:33 PM: -- It might be a

[jira] [Comment Edited] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-30 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225144#comment-16225144 ] Ben Corlett edited comment on KAFKA-6042 at 10/30/17 3:33 PM: -- It might be a

[jira] [Commented] (KAFKA-6119) Silent Data Loss in Kafka011 Transactional Producer

2017-10-30 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225152#comment-16225152 ] Guozhang Wang commented on KAFKA-6119: -- It is merged into 0.11.0 branch, but like Apurva said we do

[jira] [Comment Edited] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-30 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16225144#comment-16225144 ] Ben Corlett edited comment on KAFKA-6042 at 10/30/17 3:33 PM: -- It might be a

[jira] [Updated] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-30 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Corlett updated KAFKA-6042: --- Attachment: heapusage.png heapusage > Kafka Request Handler deadlocks and brings down the cluster. >

[jira] [Updated] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

2017-10-30 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-4499: -- Attachment: 4499-All-test-v1.patch This is my current progress, although the tests for these methods

[jira] [Commented] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224958#comment-16224958 ] ASF GitHub Bot commented on KAFKA-5520: --- Github user jeqo closed the pull request at:

[jira] [Commented] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224916#comment-16224916 ] ASF GitHub Bot commented on KAFKA-5520: --- GitHub user jeqo opened a pull request:

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

2017-10-30 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224906#comment-16224906 ] Damian Guy commented on KAFKA-4499: --- [~Yohan123] you can submit a patch as a [WIP] PR, then we will be

[jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics

2017-10-30 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas updated KAFKA-3073: --- Fix Version/s: (was: 1.0.1) 1.1.0 > KafkaConnect should support regular

[jira] [Commented] (KAFKA-3073) KafkaConnect should support regular expression for topics

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224901#comment-16224901 ] Ismael Juma commented on KAFKA-3073: The soonest this can go in is 1.1.0 since it's a new feature. >

[jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics

2017-10-30 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas updated KAFKA-3073: --- Fix Version/s: 1.0.1 > KafkaConnect should support regular expression for topics >

[jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics

2017-10-30 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas updated KAFKA-3073: --- Labels: (was: needs-kip) > KafkaConnect should support regular expression for topics >

[jira] [Resolved] (KAFKA-2995) in 0.9.0.0 Old Consumer's commitOffsets with specify partition can submit not exists topic and partition to zk

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2995. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-2062) Sync Producer, Variable Message Length, Multiple Threads = Direct memory overuse

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2062. -- Resolution: Auto Closed Closing inactive issue. The old producer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-1958) ZookeeperConsumerConnector doesn't remove consumer node on shutdown.

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1958. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-1415) Async producer.send can block forever if async.ProducerSendThread dies

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1415. -- Resolution: Auto Closed Closing inactive issue. The old producer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-1066) Reduce logging on producer connection failures

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1066. -- Resolution: Auto Closed Closing inactive issue. The old producer is no longer supported > Reduce

[jira] [Resolved] (KAFKA-1006) Consumer loses messages of a new topic with auto.offset.reset = largest

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1006. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-610) connect.timeout.ms seems to do the wrong thing in the producer

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-610. - Resolution: Auto Closed Closing inactive issue. The old producer is no longer supported. >

[jira] [Resolved] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-599. - Resolution: Auto Closed The Scala consumers are no longer supported. > SimpleConsumerShell ONLY

[jira] [Resolved] (KAFKA-435) Keep track of the transient test failure for Kafka-343 on Apache Jenkins

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-435. - Resolution: Cannot Reproduce Closing inactive issue. > Keep track of the transient test failure for

[jira] [Resolved] (KAFKA-354) Refactor getter and setter API to conform to the new convention

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-354. - Resolution: Won't Fix Closing inactive issue. > Refactor getter and setter API to conform to the new

[jira] [Resolved] (KAFKA-407) Uncaught InputStream.close() exception in CompressionUtils.compress()

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-407. - Resolution: Won't Fix This part of the code is removed. So closing the issue. > Uncaught

[jira] [Reopened] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-3917: If you're running 0.10.2.0, then potentially KAFKA-5413, but I'll reopen until we can verify. > Some

[jira] [Updated] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3917: --- Affects Version/s: (was: 0.8.2.2) 0.10.2.0 > Some __consumer_offsets

[jira] [Updated] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2580: --- Affects Version/s: (was: 0.8.2.1) 1.0.0 0.10.0.0

[jira] [Updated] (KAFKA-2588) ReplicaManager partitionCount metric should actually be replicaCount

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2588: --- Affects Version/s: (was: 0.8.2.1) 1.0.0 0.10.0.0

[jira] [Updated] (KAFKA-2588) ReplicaManager partitionCount metric should actually be replicaCount

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2588: --- Labels: needs-kip (was: ) > ReplicaManager partitionCount metric should actually be replicaCount >

[jira] [Commented] (KAFKA-2588) ReplicaManager partitionCount metric should actually be replicaCount

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224791#comment-16224791 ] Ismael Juma commented on KAFKA-2588: A KIP would be required for this. > ReplicaManager

[jira] [Updated] (KAFKA-2607) Review `Time` interface and its usage

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2607: --- Affects Version/s: (was: 0.8.2.2) 1.0.0 0.11.0.0 >

[jira] [Resolved] (KAFKA-2616) Improve Kakfa client exceptions

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2616. Resolution: Auto Closed BlockingChannel is only used by the Scala clients. which are no longer

[jira] [Updated] (KAFKA-2605) Replace `catch: Throwable` clauses with `NonFatal` or `NonControl`

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2605: --- Affects Version/s: (was: 0.8.2.2) 1.0.0 0.11.0.0 >

[jira] [Resolved] (KAFKA-2636) Producer connectivity obscured connection failure logging

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2636. Resolution: Not A Problem The producer should throw a TimeoutException to the callback or if

[jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

2017-10-30 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224784#comment-16224784 ] jaikiran pai commented on KAFKA-2561: - I just came across this JIRA, so I thought I will update it

[jira] [Resolved] (KAFKA-2662) Make ConsumerIterator thread-safe for multiple threads in different Kafka groups

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2662. Resolution: Auto Closed The Scala consumers are no longer supported. Please upgrade to the Java

[jira] [Resolved] (KAFKA-2725) high level consumer rebalances with auto-commit disabled should throw an exception

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2725. Resolution: Auto Closed The Scala consumers are no longer supported. If this still applies to the

[jira] [Updated] (KAFKA-2787) Refactor gradle build

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2787: --- Affects Version/s: (was: 0.8.2.2) > Refactor gradle build > - > >

[jira] [Updated] (KAFKA-2898) Kafka producer config incorrectly warns that serializer.* isn't a known config

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2898: --- Affects Version/s: (was: 0.8.2.1) 1.0.0 0.10.0.0

[jira] [Updated] (KAFKA-2903) FileRecords.read doesn't handle size > sizeInBytes when start is not zero

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2903: --- Fix Version/s: (was: 1.0.0) 1.1.0 > FileRecords.read doesn't handle size >

[jira] [Commented] (KAFKA-2903) FileRecords.read doesn't handle size > sizeInBytes when start is not zero

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224767#comment-16224767 ] ASF GitHub Bot commented on KAFKA-2903: --- GitHub user ijuma opened a pull request:

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224750#comment-16224750 ] Ismael Juma commented on KAFKA-6042: [~corlettb], it's unrelated to this issue so best to discuss it

[jira] [Commented] (KAFKA-5060) Offset not found while broker is rebuilding its index after an index corruption

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224722#comment-16224722 ] Ismael Juma commented on KAFKA-5060: [~rparmentier], can you include consumer logs as well? > Offset

[jira] [Commented] (KAFKA-6130) VerifiableConsumer with --max-messages doesn't exit

2017-10-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224708#comment-16224708 ] ASF GitHub Bot commented on KAFKA-6130: --- GitHub user tombentley opened a pull request:

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-30 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224617#comment-16224617 ] Ben Corlett commented on KAFKA-6042: We had another issue on broker 125 again. Not the same this time.

[jira] [Commented] (KAFKA-5060) Offset not found while broker is rebuilding its index after an index corruption

2017-10-30 Thread Romaric Parmentier (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224570#comment-16224570 ] Romaric Parmentier commented on KAFKA-5060: --- Hi Ismael, Yes we are reporting the same issue.

[jira] [Resolved] (KAFKA-788) Periodic refresh of topic metadata on the producer doesn't include all topics

2017-10-30 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-788. - Resolution: Auto Closed Closing inactive issue. The old producer is no longer supported. > Periodic

[jira] [Updated] (KAFKA-2903) FileRecords.read doesn't handle size > sizeInBytes when start is not zero

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2903: --- Description: now the code is : def read(position: Int, size: Int): FileMessageSet = { .

[jira] [Updated] (KAFKA-2903) FileRecords.read doesn't handle size > sizeInBytes when start is not zero

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2903: --- Summary: FileRecords.read doesn't handle size > sizeInBytes when start is not zero (was:

[jira] [Updated] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2903: --- Affects Version/s: (was: 0.8.2.1) (was: 0.9.0.0)

[jira] [Updated] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3042: --- Affects Version/s: (was: 0.8.2.1) 0.10.0.0 > updateIsr should stop after

[jira] [Updated] (KAFKA-3049) VerifiableProperties does not respect 'default' properties of underlying java.util.Properties instance

2017-10-30 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3049: --- Affects Version/s: (was: 0.8.2.1) (was: 0.9.0.0)

[jira] [Commented] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

2017-10-30 Thread Maxim Vladimirskiy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224456#comment-16224456 ] Maxim Vladimirskiy commented on KAFKA-3917: --- We are running on v0.10.2.0 now and it is still

[jira] [Comment Edited] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

2017-10-30 Thread Maxim Vladimirskiy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224456#comment-16224456 ] Maxim Vladimirskiy edited comment on KAFKA-3917 at 10/30/17 7:44 AM: -