[jira] [Resolved] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time.

[ https://issues.apache.org/jira/browse/KAFKA-6092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6092. -- Resolution: Fixed Have double checked the docs for coming 2.0 which is clear on the types of p

[jira] [Resolved] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies

[ https://issues.apache.org/jira/browse/KAFKA-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6355. -- Resolution: Cannot Reproduce Have not seen this issue for a while, closing for now. > transien

[jira] [Resolved] (KAFKA-5739) Rewrite KStreamPeekTest at processor level avoiding driver usage

[ https://issues.apache.org/jira/browse/KAFKA-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5739. -- Resolution: Fixed Fix Version/s: 2.0.0 This is already fixed in trunk, coming in 2.0.0

[jira] [Resolved] (KAFKA-5058) Add a sensor to KafkaStreams to track records that have been dropped due to having a null key

[ https://issues.apache.org/jira/browse/KAFKA-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5058. -- Resolution: Fixed Assignee: John Roesler Fix Version/s: 2.0.0 This has been res

[jira] [Commented] (KAFKA-5393) in-memory state store memory issue

[ https://issues.apache.org/jira/browse/KAFKA-5393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499769#comment-16499769 ] Guozhang Wang commented on KAFKA-5393: -- Is there an easy way to reproduce this issue

[jira] [Resolved] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5618. -- Resolution: Cannot Reproduce > Kafka stream not receive any topic/partitions/records info > ---

[jira] [Resolved] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3429. -- Resolution: Fixed With the new API in KIP-182 this is already resolved: the serdes will be inh

[jira] [Commented] (KAFKA-5924) Add the compose method to the Kafka Stream API

[ https://issues.apache.org/jira/browse/KAFKA-5924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499759#comment-16499759 ] Guozhang Wang commented on KAFKA-5924: -- [~Crystark] Is the new API introduced since

[jira] [Resolved] (KAFKA-5974) Removed unused parameter ProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5974. -- Resolution: Fixed Fix Version/s: 2.0.0 This has been resolved in 2.0 release. > Removed

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499755#comment-16499755 ] Guozhang Wang commented on KAFKA-6161: -- Since we have migrated to JDK8 now in 2.0, s

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499756#comment-16499756 ] ASF GitHub Bot commented on KAFKA-6161: --- guozhangwang closed pull request #4175: KA

[jira] [Resolved] (KAFKA-4960) Invalid state store exception

[ https://issues.apache.org/jira/browse/KAFKA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4960. -- Resolution: Cannot Reproduce > Invalid state store exception > - >

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499728#comment-16499728 ] Valencia Edna Serrao commented on KAFKA-6335: - Hi [~yuzhih...@gmail.com], I'

[jira] [Commented] (KAFKA-6709) broker failed to handle request due to OOM

[ https://issues.apache.org/jira/browse/KAFKA-6709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499656#comment-16499656 ] Dhruvil Shah commented on KAFKA-6709: - Fixed by KAFKA-6927. > broker failed to handl

[jira] [Updated] (KAFKA-6841) Add support for Prefixed ACLs

[ https://issues.apache.org/jira/browse/KAFKA-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Vijay updated KAFKA-6841: Summary: Add support for Prefixed ACLs (was: Add support for wildcard suffixed ACLs) > Add suppor

[jira] [Commented] (KAFKA-6900) Add thenCompose to KafkaFuture

[ https://issues.apache.org/jira/browse/KAFKA-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499565#comment-16499565 ] ASF GitHub Bot commented on KAFKA-6900: --- RichoDemus closed pull request #5080: KAFK

[jira] [Updated] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl

[ https://issues.apache.org/jira/browse/KAFKA-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6925: - Fix Version/s: 1.0.2 0.11.0.3 > Memory leak in > org.apache.kafka.streams.pro

[jira] [Resolved] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl

[ https://issues.apache.org/jira/browse/KAFKA-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6925. -- Resolution: Fixed > Memory leak in > org.apache.kafka.streams.processor.internals.StreamThread

[jira] [Commented] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl

[ https://issues.apache.org/jira/browse/KAFKA-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499506#comment-16499506 ] Guozhang Wang commented on KAFKA-6925: -- Merged separate PRs for 0.11.0, 1.0 and 1.1

[jira] [Commented] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl

[ https://issues.apache.org/jira/browse/KAFKA-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499505#comment-16499505 ] ASF GitHub Bot commented on KAFKA-6925: --- guozhangwang closed pull request #5120: KA

[jira] [Updated] (KAFKA-6976) Kafka Streams instances going in to DEAD state

[ https://issues.apache.org/jira/browse/KAFKA-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Goyal updated KAFKA-6976: Attachment: kafkaStreamsDeadState.log > Kafka Streams instances going in to DEAD state > --

[jira] [Commented] (KAFKA-6976) Kafka Streams instances going in to DEAD state

[ https://issues.apache.org/jira/browse/KAFKA-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499347#comment-16499347 ] Deepak Goyal commented on KAFKA-6976: - [^kafkaStreamsDeadState.log]  The logs attache

[jira] [Comment Edited] (KAFKA-6972) Kafka ACL does not work expected with wildcard

[ https://issues.apache.org/jira/browse/KAFKA-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499338#comment-16499338 ] Soyee Deng edited comment on KAFKA-6972 at 6/3/18 8:58 AM: --- Hi 

[jira] [Commented] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer

[ https://issues.apache.org/jira/browse/KAFKA-5523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499343#comment-16499343 ] ASF GitHub Bot commented on KAFKA-5523: --- ijuma closed pull request #5092: KAFKA-552

[jira] [Commented] (KAFKA-6972) Kafka ACL does not work expected with wildcard

[ https://issues.apache.org/jira/browse/KAFKA-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499338#comment-16499338 ] Soyee Deng commented on KAFKA-6972: --- Hi [~sliebau], Sorry, my fault. It works as you m