[jira] [Comment Edited] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732716#comment-16732716 ] Sebastian Puzoń edited comment on KAFKA-7531 at 1/3/19 7:04 AM: I'm not

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732716#comment-16732716 ] Sebastian Puzoń commented on KAFKA-7531: I'm not able to replicate this issue on same JDK as

[jira] [Comment Edited] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732715#comment-16732715 ] Sebastian Puzoń edited comment on KAFKA-7625 at 1/3/19 7:04 AM: I'm not

[jira] [Commented] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732715#comment-16732715 ] Sebastian Puzoń commented on KAFKA-7625: I'm not able to replicate this issue on same JDK as

[jira] [Commented] (KAFKA-6627) Console producer default config values override explicitly provided properties

[ https://issues.apache.org/jira/browse/KAFKA-6627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732592#comment-16732592 ] ASF GitHub Bot commented on KAFKA-6627: --- likan999 commented on pull request #6084: KAFKA-6627:

[jira] [Resolved] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests

[ https://issues.apache.org/jira/browse/KAFKA-1927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1927. - Resolution: Fixed Since the only remaining item is a refactoring, I think we can consider this

[jira] [Resolved] (KAFKA-1705) Add MR layer to Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1705. - Resolution: Won't Fix If I didn't do it by now... Also, MapReduce is so 2014 :) > Add MR layer

[jira] [Resolved] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5503. Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 > Idempotent

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732498#comment-16732498 ] ASF GitHub Bot commented on KAFKA-5503: --- hachikuji commented on pull request #5881: KAFKA-5503

[jira] [Created] (KAFKA-7783) Improve testing of idempotent/transactional producer shutdown

Jason Gustafson created KAFKA-7783: -- Summary: Improve testing of idempotent/transactional producer shutdown Key: KAFKA-7783 URL: https://issues.apache.org/jira/browse/KAFKA-7783 Project: Kafka

[jira] [Assigned] (KAFKA-6627) Console producer default config values override explicitly provided properties

[ https://issues.apache.org/jira/browse/KAFKA-6627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-6627: - Assignee: Kan Li (was: Sandor Murakozi) > Console producer default

[jira] [Commented] (KAFKA-6627) Console producer default config values override explicitly provided properties

[ https://issues.apache.org/jira/browse/KAFKA-6627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732367#comment-16732367 ] Kan Li commented on KAFKA-6627: --- Hi Sandor, if you haven't started, do you mind if I take it? I am new to

[jira] [Commented] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

[ https://issues.apache.org/jira/browse/KAFKA-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732085#comment-16732085 ] Matthias J. Sax commented on KAFKA-7743: I am nor sure if the error occurs in those test of the

[jira] [Updated] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7223: --- Fix Version/s: 2.1.0 > KIP-328: Add in-memory Suppression >

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732077#comment-16732077 ] Matthias J. Sax commented on KAFKA-7778: [~jlaskowski] thanks for reporting this. I guess it's

[jira] [Updated] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7778: --- Description: {{KTable.suppress}} is not available in Scala API.

[jira] [Assigned] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7778: -- Assignee: John Roesler > Add KTable.suppress to Scala API >

[jira] [Updated] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7778: --- Issue Type: Task (was: Bug) > Add KTable.suppress to Scala API >

[jira] [Commented] (KAFKA-7781) Add validation check for Topic retention.ms property

[ https://issues.apache.org/jira/browse/KAFKA-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732009#comment-16732009 ] ASF GitHub Bot commented on KAFKA-7781: --- kamalcph commented on pull request #6082: KAFKA-7781: Add

[jira] [Created] (KAFKA-7782) cleanup policy for offsets topic should be configurable

Nir Barel created KAFKA-7782: Summary: cleanup policy for offsets topic should be configurable Key: KAFKA-7782 URL: https://issues.apache.org/jira/browse/KAFKA-7782 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7781) Add validation check for Topic retention.ms property

Kamal Chandraprakash created KAFKA-7781: --- Summary: Add validation check for Topic retention.ms property Key: KAFKA-7781 URL: https://issues.apache.org/jira/browse/KAFKA-7781 Project: Kafka

[jira] [Updated] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values

[ https://issues.apache.org/jira/browse/KAFKA-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manohar Vanam updated KAFKA-7780: - Issue Type: Bug (was: Improvement) > Kafka client should validate topic-level configs and

[jira] [Updated] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values

[ https://issues.apache.org/jira/browse/KAFKA-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manohar Vanam updated KAFKA-7780: - Description: Kafka client should validate topic-level configs and update only unique values.

[jira] [Created] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values

Manohar Vanam created KAFKA-7780: Summary: Kafka client should validate topic-level configs and update only unique values Key: KAFKA-7780 URL: https://issues.apache.org/jira/browse/KAFKA-7780

[jira] [Commented] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode

[ https://issues.apache.org/jira/browse/KAFKA-7779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731870#comment-16731870 ] ASF GitHub Bot commented on KAFKA-7779: --- huxihx commented on pull request #6081: KAFKA-7779: Avoid

[jira] [Created] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode

huxihx created KAFKA-7779: - Summary: Avoid unnecessary loop iteration in leastLoadedNode Key: KAFKA-7779 URL: https://issues.apache.org/jira/browse/KAFKA-7779 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS

[ https://issues.apache.org/jira/browse/KAFKA-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731854#comment-16731854 ] Sarvesh Tamba commented on KAFKA-7743: -- The following unit tests throw exceptions consistently(but