[jira] [Commented] (KAFKA-7390) Enable the find-sec-bugs spotBugs plugin for Gradle

[ https://issues.apache.org/jira/browse/KAFKA-7390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705640#comment-16705640 ] Tim Nguyen commented on KAFKA-7390: --- [~omkreddy] just a quick update, it seems like the find-sec-bugs

[jira] [Commented] (KAFKA-7160) Add check for group ID length

[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705641#comment-16705641 ] Tim Nguyen commented on KAFKA-7160: --- Hi [~manme...@gmail.com] , are you still working on this task? If

[jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists

[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705605#comment-16705605 ] Anna Povzner commented on KAFKA-6388: - >From what I have investigated so far, the issue happens when

[jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists

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

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7672: - Labels: bug (was: ) > The local state not fully restored after KafkaStream rebalanced,

[jira] [Resolved] (KAFKA-4219) Permit setting of event time in stream processor

[ https://issues.apache.org/jira/browse/KAFKA-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4219. -- Resolution: Fixed Fix Version/s: 2.0.0 > Permit setting of event time in stream

[jira] [Commented] (KAFKA-4219) Permit setting of event time in stream processor

[ https://issues.apache.org/jira/browse/KAFKA-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705564#comment-16705564 ] Guozhang Wang commented on KAFKA-4219: -- [~elevy] This issue is addressed in KIP-251:

[jira] [Commented] (KAFKA-7673) Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize

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

[jira] [Commented] (KAFKA-4748) Need a way to shutdown all workers in a Streams application at the same time

[ https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705560#comment-16705560 ] Guozhang Wang commented on KAFKA-4748: -- Just a heads up, we are working on KIP-345 which should

[jira] [Updated] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7678: - Labels: bug (was: ) > Failed to close producer due to java.lang.NullPointerException >

[jira] [Commented] (KAFKA-7662) Avro schema upgrade not supported on globalTable

[ https://issues.apache.org/jira/browse/KAFKA-7662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705535#comment-16705535 ] Guozhang Wang commented on KAFKA-7662: -- [~frederic.tardif] I looked at your source code, and I think

[jira] [Updated] (KAFKA-7662) Avro schema upgrade not supported on globalTable

[ https://issues.apache.org/jira/browse/KAFKA-7662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7662: - Labels: user-experience (was: ) > Avro schema upgrade not supported on globalTable >

[jira] [Comment Edited] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705465#comment-16705465 ] Chris Egerton edited comment on KAFKA-6833 at 11/30/18 11:43 PM: -

[jira] [Commented] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705465#comment-16705465 ] Chris Egerton commented on KAFKA-6833: -- [~bob-barrett] another possible approach could be to alter

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

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

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

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

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

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

[jira] [Updated] (KAFKA-7688) Allow byte array class for Decimal Logical Types to fix Debezium Issues

[ https://issues.apache.org/jira/browse/KAFKA-7688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric C Abis updated KAFKA-7688: --- Description: Decimal Logical Type fields are failing with Kafka Connect sink tasks and showing this

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

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

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705256#comment-16705256 ] John Roesler commented on KAFKA-7660: - Hey [~pkleindl], If you have a chance to repeat the original

[jira] [Commented] (KAFKA-7093) Kafka warn messages after upgrade from 0.11.0.1 to 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705220#comment-16705220 ] Gwen Shapira commented on KAFKA-7093: - It is possible that

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705199#comment-16705199 ] Guozhang Wang commented on KAFKA-7660: -- Glad it works. I can help resolve the ticket, since the

[jira] [Resolved] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7660. -- Resolution: Fixed Assignee: John Roesler Fix Version/s: 2.2.0 > Stream Metrics

[jira] [Commented] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user

[ https://issues.apache.org/jira/browse/KAFKA-7580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705187#comment-16705187 ] Matthias J. Sax commented on KAFKA-7580: {quote}with or without any changes to the code base 

[jira] [Commented] (KAFKA-7685) Support loading trust stores from classpath

[ https://issues.apache.org/jira/browse/KAFKA-7685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705040#comment-16705040 ] Noa Resare commented on KAFKA-7685: --- There is now a KIP:

[jira] [Assigned] (KAFKA-7691) Encypt-then-MAC Delegation token metadata

[ https://issues.apache.org/jira/browse/KAFKA-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7691: - Assignee: Attila Sasvari > Encypt-then-MAC Delegation token metadata >

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704882#comment-16704882 ] Ismael Juma commented on KAFKA-5146: [~tom.dewolf] can you please paste a stacktrace of the error you

[jira] [Updated] (KAFKA-7389) Upgrade spotBugs for Java 11 support

[ https://issues.apache.org/jira/browse/KAFKA-7389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7389: --- Fix Version/s: 2.1.1 > Upgrade spotBugs for Java 11 support > >

[jira] [Resolved] (KAFKA-7676) Compile Kafka failed with Gradle 5.0

[ https://issues.apache.org/jira/browse/KAFKA-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7676. Resolution: Cannot Reproduce > Compile Kafka failed with Gradle 5.0 >

[jira] [Commented] (KAFKA-7676) Compile Kafka failed with Gradle 5.0

[ https://issues.apache.org/jira/browse/KAFKA-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704800#comment-16704800 ] Ismael Juma commented on KAFKA-7676: We are using Gradle 5.0 in trunk now, so I'm going to close

[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=16704760#comment-16704760 ] Ismael Juma commented on KAFKA-7531: Which Java version are you using? The Java code where the NPE is

[jira] [Commented] (KAFKA-6477) Add Support for Quorum-based Producer Acknowledgment

[ https://issues.apache.org/jira/browse/KAFKA-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704674#comment-16704674 ] Corentin Chary commented on KAFKA-6477: --- I meant "I would be interested to try any patch" :) I'll

[jira] [Created] (KAFKA-7691) Encypt-then-MAC Delegation token metadata

Attila Sasvari created KAFKA-7691: - Summary: Encypt-then-MAC Delegation token metadata Key: KAFKA-7691 URL: https://issues.apache.org/jira/browse/KAFKA-7691 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-3362) Update protocol schema and field doc strings

[ https://issues.apache.org/jira/browse/KAFKA-3362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704610#comment-16704610 ] ASF GitHub Bot commented on KAFKA-3362: --- andrasbeni closed pull request #3495: KAFKA-3362: Update

[jira] [Commented] (KAFKA-6987) Reimplement KafkaFuture with CompletableFuture

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

[jira] [Commented] (KAFKA-7617) Document security primitives

[ https://issues.apache.org/jira/browse/KAFKA-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704458#comment-16704458 ] ASF GitHub Bot commented on KAFKA-7617: --- omkreddy closed pull request #5906: KAFKA-7617: Add

[jira] [Resolved] (KAFKA-7617) Document security primitives

[ https://issues.apache.org/jira/browse/KAFKA-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7617. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5906

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

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Puzoń updated KAFKA-7531: --- Attachment: server.log.2018-11-29-16.gz > NPE NullPointerException at TransactionCoordinator

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

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Puzoń updated KAFKA-7531: --- Attachment: server.log.2018-11-26-16.gz > NPE NullPointerException at TransactionCoordinator

[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=16704424#comment-16704424 ] Sebastian Puzoń commented on KAFKA-7531: I got another NPE in different code fragment, logs

[jira] [Commented] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user

[ https://issues.apache.org/jira/browse/KAFKA-7580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704404#comment-16704404 ] Sarvesh Tamba commented on KAFKA-7580: -- Cloned and downloaded the 'trunk' branch -

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704399#comment-16704399 ] Patrik Kleindl commented on KAFKA-7660: --- Last question, who should "resolve" the Jira issue? I

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704395#comment-16704395 ] Patrik Kleindl commented on KAFKA-7660: --- [~vvcephei] [~guozhang] I almost reported that it didn't

[jira] [Comment Edited] (KAFKA-7690) Change disk allocation policy for multiple partitions on a broker when topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704378#comment-16704378 ] haiyangyu edited comment on KAFKA-7690 at 11/30/18 7:58 AM: [~omkreddy]

[jira] [Updated] (KAFKA-7690) Change disk allocation policy for multiple partitions on a broker when topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haiyangyu updated KAFKA-7690: - Attachment: disk_assignent_strategy.patch > Change disk allocation policy for multiple partitions on a

[jira] [Updated] (KAFKA-7690) Change disk allocation policy for multiple partitions on a broker when topic is created

[ https://issues.apache.org/jira/browse/KAFKA-7690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haiyangyu updated KAFKA-7690: - Description: h3. *Background* if target topic partitions lager than broker size when create a topic or

[jira] [Updated] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl updated KAFKA-7660: -- Attachment: (was: heapdump-1543563004522_after.hprof) > Stream Metrics - Memory Analysis >

[jira] [Updated] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl updated KAFKA-7660: -- Attachment: heapdump-1543563004522_after.hprof > Stream Metrics - Memory Analysis >