[jira] [Created] (KAFKA-7468) KafkaController no need to startup the inner kafkaScheducer when auto.leader.rebalance.enable is false

2018-10-01 Thread ZhangShuai (JIRA)
ZhangShuai created KAFKA-7468: - Summary: KafkaController no need to startup the inner kafkaScheducer when auto.leader.rebalance.enable is false Key: KAFKA-7468 URL: https://issues.apache.org/jira/browse/KAFKA-7468

[jira] [Issue Comment Deleted] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value

2018-10-01 Thread Benjamin Bianchi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Bianchi updated KAFKA-3832: Comment: was deleted (was: Hi,   I'd like to try this ticket!) > Kafka Connect's JSON

[jira] [Commented] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value

2018-10-01 Thread Benjamin Bianchi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634894#comment-16634894 ] Benjamin Bianchi commented on KAFKA-3832: - Hi,   I'd like to try this ticket! > Kafka

[jira] [Commented] (KAFKA-7467) NoSuchElementException is raised because controlBatch is empty

2018-10-01 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634878#comment-16634878 ] Ismael Juma commented on KAFKA-7467: How come this is considered minor? It seems severe since it

[jira] [Updated] (KAFKA-7467) NoSuchElementException is raised because controlBatch is empty

2018-10-01 Thread Bob Barrett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett updated KAFKA-7467: --- Description: Somehow, log cleaner died because of NoSuchElementException when it calls

[jira] [Assigned] (KAFKA-7467) NoSuchElementException is raised because controlBatch is empty

2018-10-01 Thread Bob Barrett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett reassigned KAFKA-7467: -- Assignee: Bob Barrett > NoSuchElementException is raised because controlBatch is empty >

[jira] [Updated] (KAFKA-7467) NoSuchElementException is raised because controlBatch is empty

2018-10-01 Thread Bob Barrett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett updated KAFKA-7467: --- Description: Somehow, log cleaner died because of NoSuchElementException when it calls

[jira] [Commented] (KAFKA-4218) Enable access to key in ValueTransformer

2018-10-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634781#comment-16634781 ] Matthias J. Sax commented on KAFKA-4218: [~lindong] There was no progress on KIP-149 for 2.1

[jira] [Commented] (KAFKA-7320) Provide ability to disable auto topic creation in KafkaConsumer

2018-10-01 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634780#comment-16634780 ] Dhruvil Shah commented on KAFKA-7320: - PR is ready for review: 

[jira] [Resolved] (KAFKA-7456) Serde Inheritance in Streams DSL

2018-10-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7456. Resolution: Fixed > Serde Inheritance in Streams DSL > >

[jira] [Commented] (KAFKA-7456) Serde Inheritance in Streams DSL

2018-10-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634766#comment-16634766 ] ASF GitHub Bot commented on KAFKA-7456: --- mjsax closed pull request #5521: KAFKA-7456: Serde

[jira] [Reopened] (KAFKA-4218) Enable access to key in ValueTransformer

2018-10-01 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reopened KAFKA-4218: - Thanks for working on this [~jeyhunkarimov]! For KIP-149, currently there are 4 PRs: -

[jira] [Commented] (KAFKA-7276) Consider using re2j to speed up regex operations

2018-10-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634727#comment-16634727 ] Ted Yu commented on KAFKA-7276: --- For #1, see the following:

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-10-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 10/1/18 10:42 PM: - +1 from me. was

[jira] [Commented] (KAFKA-4436) Provide builder pattern for StreamsConfig

2018-10-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634702#comment-16634702 ] ASF GitHub Bot commented on KAFKA-4436: --- wykapedia opened a new pull request #5722: [WIP]

[jira] [Commented] (KAFKA-7465) kafka-topics.sh command not honouring --disable-rack-aware property when adding partitions.

2018-10-01 Thread Suman B N (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634618#comment-16634618 ] Suman B N commented on KAFKA-7465: -- Fixed. Pull request is

[jira] [Updated] (KAFKA-7467) NoSuchElementException is raised because controlBatch is empty

2018-10-01 Thread Badai Aqrandista (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Badai Aqrandista updated KAFKA-7467: Priority: Minor (was: Major) > NoSuchElementException is raised because controlBatch is

[jira] [Created] (KAFKA-7467) NoSuchElementException is raised because controlBatch is empty

2018-10-01 Thread Badai Aqrandista (JIRA)
Badai Aqrandista created KAFKA-7467: --- Summary: NoSuchElementException is raised because controlBatch is empty Key: KAFKA-7467 URL: https://issues.apache.org/jira/browse/KAFKA-7467 Project: Kafka

[jira] [Commented] (KAFKA-7465) kafka-topics.sh command not honouring --disable-rack-aware property when adding partitions.

2018-10-01 Thread Suman B N (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634538#comment-16634538 ] Suman B N commented on KAFKA-7465: -- Working on this fix. Please assgin the jira to me. [~cmccabe]

[jira] [Created] (KAFKA-7465) kafka-topics.sh command not honouring --disable-rack-aware property when adding partitions.

2018-10-01 Thread Suman B N (JIRA)
Suman B N created KAFKA-7465: Summary: kafka-topics.sh command not honouring --disable-rack-aware property when adding partitions. Key: KAFKA-7465 URL: https://issues.apache.org/jira/browse/KAFKA-7465

[jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

2018-10-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634495#comment-16634495 ] ASF GitHub Bot commented on KAFKA-6914: --- kkonstantine opened a new pull request #5720: KAFKA-6914:

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-01 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7464: --- Affects Version/s: 2.0.0 > Fail to shutdown ReplicaManager during broker cleaned shutdown >

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-01 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7464: --- Priority: Critical (was: Major) > Fail to shutdown ReplicaManager during broker cleaned shutdown >

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-01 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7464: --- Fix Version/s: 2.0.1 > Fail to shutdown ReplicaManager during broker cleaned shutdown >

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-01 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7464: --- Fix Version/s: 2.1.0 > Fail to shutdown ReplicaManager during broker cleaned shutdown >

[jira] [Commented] (KAFKA-6051) ReplicaFetcherThread should close the ReplicaFetcherBlockingSend earlier on shutdown

2018-10-01 Thread Zhanxiang (Patrick) Huang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634331#comment-16634331 ] Zhanxiang (Patrick) Huang commented on KAFKA-6051: -- [~ijuma] Sure. I have created

[jira] [Created] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-01 Thread Zhanxiang (Patrick) Huang (JIRA)
Zhanxiang (Patrick) Huang created KAFKA-7464: Summary: Fail to shutdown ReplicaManager during broker cleaned shutdown Key: KAFKA-7464 URL: https://issues.apache.org/jira/browse/KAFKA-7464

[jira] [Commented] (KAFKA-7463) ConsoleProducer rejects producer property values with equals signs

2018-10-01 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634303#comment-16634303 ] Manikumar commented on KAFKA-7463: -- This might have fixed in KAFKA-7388. > ConsoleProducer rejects

[jira] [Commented] (KAFKA-7445) Branch one Stream in multiple Streams

2018-10-01 Thread Dennis Reiter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633953#comment-16633953 ] Dennis Reiter commented on KAFKA-7445: -- [~mjsax]: Thanks for the hint! I will give it a try.

[jira] [Commented] (KAFKA-7458) Avoid enforced processing during bootstrap phase

2018-10-01 Thread Antony Stubbs (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633951#comment-16633951 ] Antony Stubbs commented on KAFKA-7458: -- Related to KAFKA-4113 > Avoid enforced processing during

[jira] [Created] (KAFKA-7463) ConsoleProducer rejects producer property values with equals signs

2018-10-01 Thread Magnus Reftel (JIRA)
Magnus Reftel created KAFKA-7463: Summary: ConsoleProducer rejects producer property values with equals signs Key: KAFKA-7463 URL: https://issues.apache.org/jira/browse/KAFKA-7463 Project: Kafka

[jira] [Updated] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation

2018-10-01 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-5682: --- Fix Version/s: (was: 2.1.0) 2.2.0 > Consumer should include

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-10-01 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633793#comment-16633793 ] Rajini Sivaram commented on KAFKA-7304: --- [~yuyang08] We saw the OOM during a load test, so CPU

[jira] [Commented] (KAFKA-7450) "Handshake message sequence violation" related ssl handshake failure leads to high cpu usage

2018-10-01 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633779#comment-16633779 ] Rajini Sivaram commented on KAFKA-7450: --- The exceptions indicate an SSL configuration issue. If

[jira] [Created] (KAFKA-7462) Kafka brokers cannot provide OAuth without a token

2018-10-01 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-7462: - Summary: Kafka brokers cannot provide OAuth without a token Key: KAFKA-7462 URL: https://issues.apache.org/jira/browse/KAFKA-7462 Project: Kafka Issue

[jira] [Resolved] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

2018-10-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5836. Resolution: Duplicate > Kafka Streams - API for specifying internal stream name on join >