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

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652812#comment-16652812 ] Dong Lin commented on KAFKA-7464: - [~ijuma] Previously I marked this issue as blocker because the effect

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

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Priority: Critical (was: Blocker) > Fail to shutdown ReplicaManager during broker cleaned shutdown >

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652602#comment-16652602 ] Mr Kafka commented on KAFKA-7510: - To Kafka the key and value are just bytes, those bytes may be anything

[jira] [Resolved] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

[ https://issues.apache.org/jira/browse/KAFKA-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota resolved KAFKA-7512. -- Resolution: Duplicate > java.lang.ClassCastException: java.util.Date cannot be cast to >

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652560#comment-16652560 ] John Roesler commented on KAFKA-7510: - Hi [~MrKafka], Can you comment on why the record key should

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

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652396#comment-16652396 ] Zhanxiang (Patrick) Huang commented on KAFKA-7464: -- [~ijuma]  I was waiting to see

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

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652394#comment-16652394 ] ASF GitHub Bot commented on KAFKA-7464: --- hzxa21 opened a new pull request #5808: KAFKA-7464: catch

[jira] [Updated] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7471: --- Fix Version/s: (was: 2.0.1) 2.2.0 > Multiple Consumer Group Management

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

[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652198#comment-16652198 ] Ismael Juma commented on KAFKA-7464: [~hzxa21], are you planning to submit a fix for this? It's

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

[ https://issues.apache.org/jira/browse/KAFKA-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7465: --- Fix Version/s: (was: 2.0.1) > kafka-topics.sh command not honouring --disable-rack-aware

[jira] [Resolved] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7196. Resolution: Fixed > Remove heartbeat delayed operation for those removed consumers at the end of

[jira] [Updated] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required

[ https://issues.apache.org/jira/browse/KAFKA-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7045: --- Fix Version/s: 2.2.0 > Consumer may not be able to consume all messages when down-conversion is >

[jira] [Updated] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required

[ https://issues.apache.org/jira/browse/KAFKA-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7045: --- Fix Version/s: (was: 2.0.1) 2.1.1 > Consumer may not be able to consume all

[jira] [Commented] (KAFKA-7501) double deallocation of producer batch upon expiration of inflight requests and error response

[ https://issues.apache.org/jira/browse/KAFKA-7501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652159#comment-16652159 ] ASF GitHub Bot commented on KAFKA-7501: --- xiowu0 opened a new pull request #5807: KAFKA-7501: fix

[jira] [Resolved] (KAFKA-7513) Flaky test SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain

[ https://issues.apache.org/jira/browse/KAFKA-7513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7513. --- Resolution: Fixed Reviewer: Ismael Juma > Flaky test

[jira] [Commented] (KAFKA-7513) Flaky test SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain

[ https://issues.apache.org/jira/browse/KAFKA-7513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652026#comment-16652026 ] ASF GitHub Bot commented on KAFKA-7513: --- rajinisivaram closed pull request #5805: KAFKA-7513: Fix

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652023#comment-16652023 ] Sathish Yanamala commented on KAFKA-7508: - Hi ManiKumar, We have our Java Heap - 10 GB  We have

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651985#comment-16651985 ] Manikumar commented on KAFKA-7508: -- [~sathish051] Exception message shows "java.lang.OutOfMemoryError".

[jira] [Updated] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sathish Yanamala updated KAFKA-7508: Component/s: config admin > Kafka broker anonymous disconnected from

[jira] [Comment Edited] (KAFKA-7425) Kafka Broker -Unable to start

[ https://issues.apache.org/jira/browse/KAFKA-7425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651969#comment-16651969 ] Sathish Yanamala edited comment on KAFKA-7425 at 10/16/18 3:52 PM: --- Hi

[jira] [Commented] (KAFKA-7425) Kafka Broker -Unable to start

[ https://issues.apache.org/jira/browse/KAFKA-7425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651969#comment-16651969 ] Sathish Yanamala commented on KAFKA-7425: - Hi Manikumar,   Can you please help on below stoory

[jira] [Updated] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sathish Yanamala updated KAFKA-7508: Priority: Blocker (was: Major) Component/s: (was: config) > Kafka broker

[jira] [Commented] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651951#comment-16651951 ] ASF GitHub Bot commented on KAFKA-7080: --- vvcephei opened a new pull request #5806: KAFKA-7080 and

[jira] [Updated] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7510: - Labels: user-experience (was: ) > KStreams RecordCollectorImpl leaks data to logs on error >

[jira] [Resolved] (KAFKA-7496) KafkaAdminClient#describeAcls should handle invalid filters gracefully

[ https://issues.apache.org/jira/browse/KAFKA-7496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7496. --- Resolution: Fixed Reviewer: Rajini Sivaram Fix Version/s: 2.1.0 >

[jira] [Updated] (KAFKA-7515) Trogdor - Add Consumer Group Benchmark Specification

[ https://issues.apache.org/jira/browse/KAFKA-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7515: --- Description: Trogdor's `ConsumeBenchWorker` and `ConsumeBenchSpec` currently takes

[jira] [Updated] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7514: --- Description: Trogdor's ConsumeBenchWorker currently uses only two threads - one for

[jira] [Updated] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7514: --- Description: Trogdor's ConsumeBenchWorker currently uses only two threads - one for

[jira] [Updated] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7514: --- Description: Trogdor's ConsumeBenchWorker currently uses only two threads - one for

[jira] [Created] (KAFKA-7515) Trogdor - Add Consumer Group Benchmark Specification

Stanislav Kozlovski created KAFKA-7515: -- Summary: Trogdor - Add Consumer Group Benchmark Specification Key: KAFKA-7515 URL: https://issues.apache.org/jira/browse/KAFKA-7515 Project: Kafka

[jira] [Created] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

Stanislav Kozlovski created KAFKA-7514: -- Summary: Trogdor - Support Multiple Threads in ConsumeBenchWorker Key: KAFKA-7514 URL: https://issues.apache.org/jira/browse/KAFKA-7514 Project: Kafka

[jira] [Commented] (KAFKA-7496) KafkaAdminClient#describeAcls should handle invalid filters gracefully

[ https://issues.apache.org/jira/browse/KAFKA-7496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651498#comment-16651498 ] ASF GitHub Bot commented on KAFKA-7496: --- rajinisivaram closed pull request #5774: KAFKA-7496:

[jira] [Commented] (KAFKA-7513) Flaky test SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain

[ https://issues.apache.org/jira/browse/KAFKA-7513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651489#comment-16651489 ] ASF GitHub Bot commented on KAFKA-7513: --- rajinisivaram opened a new pull request #5805: KAFKA-7513:

[jira] [Created] (KAFKA-7513) Flaky test SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain

Rajini Sivaram created KAFKA-7513: - Summary: Flaky test SaslAuthenticatorFailureDelayTest.testInvalidPasswordSaslPlain Key: KAFKA-7513 URL: https://issues.apache.org/jira/browse/KAFKA-7513 Project:

[jira] [Updated] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

[ https://issues.apache.org/jira/browse/KAFKA-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Kumar Gupta updated KAFKA-7512: - Description: Steps: ~~ bash-4.2# kafka-avro-console-producer --broker-list

[jira] [Updated] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

[ https://issues.apache.org/jira/browse/KAFKA-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Kumar Gupta updated KAFKA-7512: - Priority: Critical (was: Major) > java.lang.ClassCastException: java.util.Date cannot

[jira] [Updated] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

[ https://issues.apache.org/jira/browse/KAFKA-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Kumar Gupta updated KAFKA-7512: - Priority: Blocker (was: Critical) > java.lang.ClassCastException: java.util.Date cannot

[jira] [Updated] (KAFKA-7511) Fetch offset 2287878 is out of range for partition CommitTrn-0, resetting offset

[ https://issues.apache.org/jira/browse/KAFKA-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitesh Kumar updated KAFKA-7511: Priority: Critical (was: Major) > Fetch offset 2287878 is out of range for partition

[jira] [Updated] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

[ https://issues.apache.org/jira/browse/KAFKA-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Kumar Gupta updated KAFKA-7512: - Attachment: connect.out > java.lang.ClassCastException: java.util.Date cannot be cast to

[jira] [Created] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

Rohit Kumar Gupta created KAFKA-7512: Summary: java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number Key: KAFKA-7512 URL: https://issues.apache.org/jira/browse/KAFKA-7512

[jira] [Created] (KAFKA-7511) Fetch offset 2287878 is out of range for partition CommitTrn-0, resetting offset

Hitesh Kumar created KAFKA-7511: --- Summary: Fetch offset 2287878 is out of range for partition CommitTrn-0, resetting offset Key: KAFKA-7511 URL: https://issues.apache.org/jira/browse/KAFKA-7511