[jira] [Resolved] (KAFKA-6672) ConfigCommand failing to alter configs

[ https://issues.apache.org/jira/browse/KAFKA-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6672. Resolution: Fixed Fix Version/s: 1.2.0 > ConfigCommand failing to alter configs >

[jira] [Commented] (KAFKA-6672) ConfigCommand failing to alter configs

[ https://issues.apache.org/jira/browse/KAFKA-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403118#comment-16403118 ] ASF GitHub Bot commented on KAFKA-6672: --- hachikuji opened a new pull request #4727: KAFKA-6672;

[jira] [Resolved] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable

[ https://issues.apache.org/jira/browse/KAFKA-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6658. Resolution: Fixed Fix Version/s: 1.2.0 > Fix RoundTripWorkload and make k/v

[jira] [Assigned] (KAFKA-6052) Windows: Consumers not polling when isolation.level=read_committed

[ https://issues.apache.org/jira/browse/KAFKA-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-6052: -- Assignee: Vahid Hashemian > Windows: Consumers not polling when

[jira] [Created] (KAFKA-6672) ConfigCommand failing to alter configs

Jason Gustafson created KAFKA-6672: -- Summary: ConfigCommand failing to alter configs Key: KAFKA-6672 URL: https://issues.apache.org/jira/browse/KAFKA-6672 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-6663) Expression for GlobalKTable is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6663: --- Affects Version/s: 1.1.0 1.0.1 > Expression for GlobalKTable is not

[jira] [Commented] (KAFKA-6671) Consumer group coordinator releases group before new coordinator is ready.

[ https://issues.apache.org/jira/browse/KAFKA-6671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402461#comment-16402461 ] Jason Gustafson commented on KAFKA-6671: I mentioned the case I'm aware of in which slow loading

[jira] [Commented] (KAFKA-6663) Expression for GlobalKTable is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402453#comment-16402453 ] ASF GitHub Bot commented on KAFKA-6663: --- mjsax closed pull request #4723: KAFKA-6663: Doc for

[jira] [Commented] (KAFKA-6667) Issues in kafka Streaming when using encryption with custom serializers and deserializers

[ https://issues.apache.org/jira/browse/KAFKA-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402435#comment-16402435 ] Matthias J. Sax commented on KAFKA-6667: As the error message indicates, you try to write a

[jira] [Resolved] (KAFKA-6667) Issues in kafka Streaming when using encryption with custom serializers and deserializers

[ https://issues.apache.org/jira/browse/KAFKA-6667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6667. Resolution: Invalid > Issues in kafka Streaming when using encryption with custom

[jira] [Updated] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

[ https://issues.apache.org/jira/browse/KAFKA-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Konstantinov updated KAFKA-6665: --- Fix Version/s: 0.10.2.0 > LeaderChangeListener.handleDataDeleted deadlock >

[jira] [Resolved] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

[ https://issues.apache.org/jira/browse/KAFKA-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Konstantinov resolved KAFKA-6665. Resolution: Duplicate > LeaderChangeListener.handleDataDeleted deadlock >

[jira] [Commented] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

[ https://issues.apache.org/jira/browse/KAFKA-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402354#comment-16402354 ] Dmitry Konstantinov commented on KAFKA-6665: Thank you for the notice. Looked though commit

[jira] [Commented] (KAFKA-6671) Consumer group coordinator releases group before new coordinator is ready.

[ https://issues.apache.org/jira/browse/KAFKA-6671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402348#comment-16402348 ] Rob Gevers commented on KAFKA-6671: --- [~hachikuji] We have had issues more consistently with a cluster

[jira] [Commented] (KAFKA-6671) Consumer group coordinator releases group before new coordinator is ready.

[ https://issues.apache.org/jira/browse/KAFKA-6671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402337#comment-16402337 ] Jason Gustafson commented on KAFKA-6671: One cause of slow coordinator failover is an oversized

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402326#comment-16402326 ] Filipe Agapito commented on KAFKA-6474: --- Hi John, I also ran into the cyclic dependency issue. For

[jira] [Created] (KAFKA-6671) Consumer group coordinator releases group before new coordinator is ready.

Rob Gevers created KAFKA-6671: - Summary: Consumer group coordinator releases group before new coordinator is ready. Key: KAFKA-6671 URL: https://issues.apache.org/jira/browse/KAFKA-6671 Project: Kafka

[jira] [Commented] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

[ https://issues.apache.org/jira/browse/KAFKA-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402165#comment-16402165 ] Eugene Sevastyanov commented on KAFKA-6665: --- Just for information, checked 0.10.2, there is no

[jira] [Comment Edited] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

[ https://issues.apache.org/jira/browse/KAFKA-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402165#comment-16402165 ] Eugene Sevastyanov edited comment on KAFKA-6665 at 3/16/18 4:44 PM:

[jira] [Updated] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6670: --- Description: Implement a Scala wrapper library for Kafka Streams. KIP: 

[jira] [Assigned] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6670: -- Assignee: Debasish Ghosh > Implement a Scala wrapper library for Kafka Streams >

[jira] [Updated] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6670: --- Labels: api kip (was: api needs-kip) > Implement a Scala wrapper library for Kafka Streams >

[jira] [Updated] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6670: - Labels: api needs-kip (was: ) > Implement a Scala wrapper library for Kafka Streams >

[jira] [Updated] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6670: - Affects Version/s: (was: 1.0.1) (was: 1.0.0) > Implement a Scala

[jira] [Created] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

Debasish Ghosh created KAFKA-6670: - Summary: Implement a Scala wrapper library for Kafka Streams Key: KAFKA-6670 URL: https://issues.apache.org/jira/browse/KAFKA-6670 Project: Kafka Issue

[jira] [Commented] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401932#comment-16401932 ] Mehmet Soner commented on KAFKA-5962: - How can i configure JDK in order to allow large sized memory

[jira] [Commented] (KAFKA-6669) KIP-271: Add NetworkClient redirector

[ https://issues.apache.org/jira/browse/KAFKA-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401859#comment-16401859 ] Sergey Korytnikov commented on KAFKA-6669: -- *Usa-case example:*  Kafka cluster is running in

[jira] [Updated] (KAFKA-6669) KIP-271: Add NetworkClient redirector

[ https://issues.apache.org/jira/browse/KAFKA-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Korytnikov updated KAFKA-6669: - Description: "KIP-271 Add NetworkClient redirector" purposes the change to accommodate

[jira] [Created] (KAFKA-6669) KIP-271: Add NetworkClient redirector

Sergey Korytnikov created KAFKA-6669: Summary: KIP-271: Add NetworkClient redirector Key: KAFKA-6669 URL: https://issues.apache.org/jira/browse/KAFKA-6669 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401781#comment-16401781 ] Umesh Chaudhary commented on KAFKA-5962: Seems somewhat related to KAFKA-2560, please verify if

[jira] [Created] (KAFKA-6668) Broker crashes on restart ,got a CorruptRecordException: Record size is smaller than minimum record overhead(14)

mayong created KAFKA-6668: - Summary: Broker crashes on restart ,got a CorruptRecordException: Record size is smaller than minimum record overhead(14) Key: KAFKA-6668 URL: https://issues.apache.org/jira/browse/KAFKA-6668

[jira] [Comment Edited] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401589#comment-16401589 ] Mehmet Soner edited comment on KAFKA-5962 at 3/16/18 8:28 AM: --   Hi,

[jira] [Commented] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401589#comment-16401589 ] Mehmet Soner commented on KAFKA-5962: - [^broker-log-failed-during-restart.txt]   Hi,

[jira] [Updated] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mehmet Soner updated KAFKA-5962: Attachment: broker-log-start-and-shutdown.txt broker-log-failed-during-restart.txt

[jira] [Created] (KAFKA-6667) Issues in kafka Streaming when using encryption with custom serializers and deserializers

Amandeep Singh created KAFKA-6667: - Summary: Issues in kafka Streaming when using encryption with custom serializers and deserializers Key: KAFKA-6667 URL: https://issues.apache.org/jira/browse/KAFKA-6667

[jira] [Commented] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401533#comment-16401533 ] Umesh Chaudhary commented on KAFKA-5962: [~msoner], would you mind attaching the full broker logs

[jira] [Commented] (KAFKA-4368) Unclean shutdown breaks Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401527#comment-16401527 ] Umesh Chaudhary commented on KAFKA-4368: [~Anukool] are you still seeing this behavior with trunk?