[jira] [Resolved] (KAFKA-4160) Consumer onPartitionsRevoked should not be invoked while holding the coordinator lock

[ https://issues.apache.org/jira/browse/KAFKA-4160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4160. -- Resolution: Fixed Issue resolved by pull request 1855

[jira] [Commented] (KAFKA-4153) Incorrect KStream-KStream join behavior with asymmetric time window

[ https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491329#comment-15491329 ] Guozhang Wang commented on KAFKA-4153: -- According to the stated Java doc string, {{JoinWindows}}

[jira] [Reopened] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4058: -- Re-open this issue since this transient error is still observable. Sharing [~enothereska] 's stack

[jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3595: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Resolved] (KAFKA-4123) Queryable State returning null for key before all stores in instance have been initialized

[ https://issues.apache.org/jira/browse/KAFKA-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4123. -- Resolution: Fixed Issue resolved by pull request 1824

[jira] [Created] (KAFKA-4143) Transient failure in kafka.server.SaslSslReplicaFetchTest.testReplicaFetcherThread

Guozhang Wang created KAFKA-4143: Summary: Transient failure in kafka.server.SaslSslReplicaFetchTest.testReplicaFetcherThread Key: KAFKA-4143 URL: https://issues.apache.org/jira/browse/KAFKA-4143

[jira] [Updated] (KAFKA-4118) StreamsSmokeTest.test_streams started failing since 18 August build

[ https://issues.apache.org/jira/browse/KAFKA-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4118: - Assignee: Eno Thereska (was: Guozhang Wang) > StreamsSmokeTest.test_streams started failing

[jira] [Commented] (KAFKA-4118) StreamsSmokeTest.test_streams started failing since 18 August build

[ https://issues.apache.org/jira/browse/KAFKA-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472260#comment-15472260 ] Guozhang Wang commented on KAFKA-4118: -- [~enothereska] Could you take a look at this issue? Thanks!

[jira] [Updated] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4058: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468825#comment-15468825 ] Guozhang Wang commented on KAFKA-3478: -- [~mjsax] Since separate JIRAs have been created for these two

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468817#comment-15468817 ] Guozhang Wang commented on KAFKA-4113: -- More thoughts regarding this issue after discussing with

[jira] [Comment Edited] (KAFKA-3779) Add the LRU cache for KTable.to() operator

[ https://issues.apache.org/jira/browse/KAFKA-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468453#comment-15468453 ] Guozhang Wang edited comment on KAFKA-3779 at 9/6/16 8:29 PM: -- Thanks for the

[jira] [Commented] (KAFKA-3779) Add the LRU cache for KTable.to() operator

[ https://issues.apache.org/jira/browse/KAFKA-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468453#comment-15468453 ] Guozhang Wang commented on KAFKA-3779: -- Thanks for the explanation, LGTM. Just for keeping track in

[jira] [Commented] (KAFKA-3779) Add the LRU cache for KTable.to() operator

[ https://issues.apache.org/jira/browse/KAFKA-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468302#comment-15468302 ] Guozhang Wang commented on KAFKA-3779: -- Are all KTable changelog stream contains deduped data even

[jira] [Commented] (KAFKA-4043) User-defined handler for topology restart

[ https://issues.apache.org/jira/browse/KAFKA-4043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468278#comment-15468278 ] Guozhang Wang commented on KAFKA-4043: -- Hi [~gfodor], when there is a rebalance happening and some

[jira] [Updated] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

[ https://issues.apache.org/jira/browse/KAFKA-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4023: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-3769) KStream job spending 60% of time writing metrics

[ https://issues.apache.org/jira/browse/KAFKA-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468157#comment-15468157 ] Guozhang Wang commented on KAFKA-3769: -- Yes please :) Also is it a general issue in {{Selector}}

[jira] [Commented] (KAFKA-4120) byte[] keys in RocksDB state stores do not work as expected

[ https://issues.apache.org/jira/browse/KAFKA-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15464109#comment-15464109 ] Guozhang Wang commented on KAFKA-4120: -- Hi [~gfodor], thanks for reporting this issue. We found this

[jira] [Resolved] (KAFKA-4105) Queryable state tests for concurrency and rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-4105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4105. -- Resolution: Fixed Issue resolved by pull request 1806

[jira] [Updated] (KAFKA-4117) Cleanup StreamPartitionAssignor behavior

[ https://issues.apache.org/jira/browse/KAFKA-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4117: - Description: I went through the whole assignment logic once again and I feel the logic has now

[jira] [Created] (KAFKA-4117) Cleanup StreamPartitionAssignor behavior

Guozhang Wang created KAFKA-4117: Summary: Cleanup StreamPartitionAssignor behavior Key: KAFKA-4117 URL: https://issues.apache.org/jira/browse/KAFKA-4117 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-4104) Queryable state metadata is sometimes invalid

[ https://issues.apache.org/jira/browse/KAFKA-4104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4104: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Resolved] (KAFKA-4112) Remove alpha quality label from Kafka Streams in docs

[ https://issues.apache.org/jira/browse/KAFKA-4112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4112. -- Resolution: Fixed Fix Version/s: 0.10.0.2 0.10.1.0 > Remove alpha

[jira] [Commented] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453098#comment-15453098 ] Guozhang Wang commented on KAFKA-4106: -- [~fhussonnois] {PartitionAssignor} extends {Configurable} and

[jira] [Comment Edited] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15453098#comment-15453098 ] Guozhang Wang edited comment on KAFKA-4106 at 8/31/16 7:11 PM: ---

[jira] [Commented] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433652#comment-15433652 ] Guozhang Wang commented on KAFKA-3758: -- [~stliu] [~gfodor] With KAFKA-3888 merged into trunk this

[jira] [Commented] (KAFKA-3559) Task creation time taking too long in rebalance callback

[ https://issues.apache.org/jira/browse/KAFKA-3559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433648#comment-15433648 ] Guozhang Wang commented on KAFKA-3559: -- With KIP-62 (KAFKA-3888) merged into trunk, this issue should

[jira] [Resolved] (KAFKA-4049) Transient failure in RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-4049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4049. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1746

[jira] [Created] (KAFKA-4075) Failure in SaslSslTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack

Guozhang Wang created KAFKA-4075: Summary: Failure in SaslSslTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack Key: KAFKA-4075 URL: https://issues.apache.org/jira/browse/KAFKA-4075 Project:

[jira] [Resolved] (KAFKA-3949) Consumer topic subscription change may be ignored if a rebalance is in progress

[ https://issues.apache.org/jira/browse/KAFKA-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3949. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1762

[jira] [Resolved] (KAFKA-4016) Kafka Streams join benchmark

[ https://issues.apache.org/jira/browse/KAFKA-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4016. -- Resolution: Fixed Issue resolved by pull request 1700

[jira] [Updated] (KAFKA-4060) Remove ZkClient dependency in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4060: - Assignee: Hojjat Jafarpour > Remove ZkClient dependency in Kafka Streams >

[jira] [Updated] (KAFKA-4060) Remove ZkClient dependency in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4060: - Description: In Kafka Streams we need to dynamically create or update those internal topics

[jira] [Created] (KAFKA-4060) Remove ZkClient dependency in Kafka Streams

Guozhang Wang created KAFKA-4060: Summary: Remove ZkClient dependency in Kafka Streams Key: KAFKA-4060 URL: https://issues.apache.org/jira/browse/KAFKA-4060 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-3888) Allow consumer to send heartbeats in background thread (KIP-62)

[ https://issues.apache.org/jira/browse/KAFKA-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3888. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1627

[jira] [Created] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

Guozhang Wang created KAFKA-4058: Summary: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset Key: KAFKA-4058 URL:

[jira] [Updated] (KAFKA-4049) Transient failure in RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-4049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4049: - Description: There is an hidden assumption in this test case that the created {{TEST-TOPIC-A}}

[jira] [Updated] (KAFKA-4049) Transient failure in RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-4049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4049: - Description: There is a race condition in > Transient failure in >

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15423285#comment-15423285 ] Guozhang Wang commented on KAFKA-3410: -- [~wushujames] Could you check if KAFKA-3924 fixed this issue?

[jira] [Created] (KAFKA-4049) Transient failure in RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted

Guozhang Wang created KAFKA-4049: Summary: Transient failure in RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted Key: KAFKA-4049 URL: https://issues.apache.org/jira/browse/KAFKA-4049

[jira] [Resolved] (KAFKA-3914) Global discovery of state stores

[ https://issues.apache.org/jira/browse/KAFKA-3914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3914. -- Resolution: Fixed Issue resolved by pull request 1576

[jira] [Updated] (KAFKA-3936) Validate user parameters as early as possible

[ https://issues.apache.org/jira/browse/KAFKA-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3936: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-3936) Validate user parameters as early as possible

[ https://issues.apache.org/jira/browse/KAFKA-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3936: - Assignee: Damian Guy (was: Guozhang Wang) > Validate user parameters as early as possible >

[jira] [Created] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

Guozhang Wang created KAFKA-4023: Summary: Add thread id as prefix in Kafka Streams thread logging Key: KAFKA-4023 URL: https://issues.apache.org/jira/browse/KAFKA-4023 Project: Kafka Issue

[jira] [Commented] (KAFKA-3752) Provide a way for KStreams to recover from unclean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15406893#comment-15406893 ] Guozhang Wang commented on KAFKA-3752: -- [~theduderog] Do you still have the logs on the server side?

[jira] [Commented] (KAFKA-2063) Bound fetch response size

[ https://issues.apache.org/jira/browse/KAFKA-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15406730#comment-15406730 ] Guozhang Wang commented on KAFKA-2063: -- Another note from Streams is that in situations where

[jira] [Commented] (KAFKA-2063) Bound fetch response size

[ https://issues.apache.org/jira/browse/KAFKA-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15406623#comment-15406623 ] Guozhang Wang commented on KAFKA-2063: -- Re 1) Currently we use pause / resume per partition to avoid

[jira] [Resolved] (KAFKA-1143) Consumer should cache topic partition info

[ https://issues.apache.org/jira/browse/KAFKA-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1143. -- Resolution: Duplicate Fix Version/s: (was: 0.10.1.0) This ticket was proposed for

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15406121#comment-15406121 ] Guozhang Wang commented on KAFKA-3042: -- I agree that we should consider improving the controller

[jira] [Commented] (KAFKA-3817) KTableRepartitionMap should handle null inputs

[ https://issues.apache.org/jira/browse/KAFKA-3817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15405982#comment-15405982 ] Guozhang Wang commented on KAFKA-3817: -- Good point, mind filing a minor PR? > KTableRepartitionMap

[jira] [Updated] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3929: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15396508#comment-15396508 ] Guozhang Wang commented on KAFKA-3705: -- Yeah currently we do not have a windowed-stream table join,

[jira] [Comment Edited] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15396491#comment-15396491 ] Guozhang Wang edited comment on KAFKA-3705 at 7/27/16 10:03 PM: We are

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15396491#comment-15396491 ] Guozhang Wang commented on KAFKA-3705: -- We are fixing this issue right now on the consumer layer with

[jira] [Updated] (KAFKA-3185) Allow users to cleanup internal data

[ https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3185: - Resolution: Fixed Fix Version/s: (was: 0.10.1.0) 0.10.0.1

[jira] [Commented] (KAFKA-3981) Possible race condition between controller cache and ZK on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15392891#comment-15392891 ] Guozhang Wang commented on KAFKA-3981: -- [~mjsax] Have you figured out the root cause of your observed

[jira] [Resolved] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3887. -- Resolution: Fixed > StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing >

[jira] [Commented] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15392273#comment-15392273 ] Guozhang Wang commented on KAFKA-3887: -- Streams system test has been resolved as of KAFKA-3911. >

[jira] [Commented] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388630#comment-15388630 ] Guozhang Wang commented on KAFKA-3887: -- This seems to be a regression that was introduced in

[jira] [Resolved] (KAFKA-3911) Enforce KTable materialization

[ https://issues.apache.org/jira/browse/KAFKA-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3911. -- Resolution: Fixed Issue resolved by pull request 1638

[jira] [Commented] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388440#comment-15388440 ] Guozhang Wang commented on KAFKA-3929: -- Thanks! I will let Damian to pick it up then. > Add prefix

[jira] [Resolved] (KAFKA-3858) Add functions to print stream topologies

[ https://issues.apache.org/jira/browse/KAFKA-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3858. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1619

[jira] [Commented] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388137#comment-15388137 ] Guozhang Wang commented on KAFKA-3929: -- [~imandhan] Are you already working on this ticket? > Add

[jira] [Resolved] (KAFKA-3740) Enable configuration of RocksDBStores

[ https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3740. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1640

[jira] [Updated] (KAFKA-3915) LogCleaner IO buffers do not account for potential size difference due to message format change

[ https://issues.apache.org/jira/browse/KAFKA-3915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3915: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[jira] [Resolved] (KAFKA-3812) State store locking is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3812. -- Resolution: Fixed Issue resolved by pull request 1628

[jira] [Resolved] (KAFKA-3912) Query local state stores

[ https://issues.apache.org/jira/browse/KAFKA-3912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3912. -- Resolution: Fixed Issue resolved by pull request 1565

[jira] [Resolved] (KAFKA-3922) Add a copy-constructor to AbstractStream

[ https://issues.apache.org/jira/browse/KAFKA-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3922. -- Resolution: Fixed Fix Version/s: 0.10.0.1 0.10.1.0 Issue resolved by

[jira] [Resolved] (KAFKA-3855) Guard race conditions in TopologyBuilder

[ https://issues.apache.org/jira/browse/KAFKA-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3855. -- Resolution: Fixed Fix Version/s: 0.10.0.1 Issue resolved by pull request 1633

[jira] [Resolved] (KAFKA-3870) Expose state store names to DSL

[ https://issues.apache.org/jira/browse/KAFKA-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3870. -- Resolution: Fixed Issue resolved by pull request 1526

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15379721#comment-15379721 ] Guozhang Wang commented on KAFKA-3729: -- Currently there are two ways to specify serde classes in

[jira] [Updated] (KAFKA-3952) VerifyConsumerRebalance cannot succeed when checking partition owner

[ https://issues.apache.org/jira/browse/KAFKA-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3952: - Assignee: Simon Wan Wenli > VerifyConsumerRebalance cannot succeed when checking partition owner

[jira] [Updated] (KAFKA-3952) VerifyConsumerRebalance cannot succeed when checking partition owner

[ https://issues.apache.org/jira/browse/KAFKA-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3952: - Resolution: Fixed Status: Resolved (was: Patch Available) > VerifyConsumerRebalance

[jira] [Updated] (KAFKA-3952) VerifyConsumerRebalance cannot succeed when checking partition owner

[ https://issues.apache.org/jira/browse/KAFKA-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3952: - Fix Version/s: 0.8.2.2 0.9.0.2 0.10.0.1 >

[jira] [Resolved] (KAFKA-3941) Avoid applying eviction listener in InMemoryKeyValueLoggedStore

[ https://issues.apache.org/jira/browse/KAFKA-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3941. -- Resolution: Fixed Fix Version/s: 0.10.0.1 Issue resolved by pull request 1610

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375673#comment-15375673 ] Guozhang Wang commented on KAFKA-3101: -- This LGTM, also we want to get some information on how

[jira] [Updated] (KAFKA-3941) Avoid applying eviction listener in InMemoryKeyValueLoggedStore

[ https://issues.apache.org/jira/browse/KAFKA-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3941: - Description: This is reported by [~norwood]. In {{InMemoryKeyValueLoggedStore}} we set the

[jira] [Commented] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375381#comment-15375381 ] Guozhang Wang commented on KAFKA-3929: -- I am sorry for the late reply, missed your response in my

[jira] [Resolved] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3887. -- Resolution: Fixed Marking as fixed per 1611. > StreamBounceTest.test_bounce and

[jira] [Updated] (KAFKA-3931) kafka.api.PlaintextConsumerTest.testPatternUnsubscription transient failure

[ https://issues.apache.org/jira/browse/KAFKA-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3931: - Resolution: Fixed Fix Version/s: 0.10.0.1 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-3949) Consumer topic subscription change may be ignored if a rebalance is in progress

[ https://issues.apache.org/jira/browse/KAFKA-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372139#comment-15372139 ] Guozhang Wang commented on KAFKA-3949: -- Thanks [~hachikuji], this is a good find! > Consumer topic

[jira] [Commented] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15371829#comment-15371829 ] Guozhang Wang commented on KAFKA-3887: -- Did some investigation on

[jira] [Resolved] (KAFKA-3882) Integration failures on low-end machines

[ https://issues.apache.org/jira/browse/KAFKA-3882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3882. -- Resolution: Not A Bug I found out this is actually due to an issue on my local machine. >

[jira] [Created] (KAFKA-3941) Avoid applying eviction listener in InMemoryKeyValueLoggedStore

Guozhang Wang created KAFKA-3941: Summary: Avoid applying eviction listener in InMemoryKeyValueLoggedStore Key: KAFKA-3941 URL: https://issues.apache.org/jira/browse/KAFKA-3941 Project: Kafka

[jira] [Commented] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15368817#comment-15368817 ] Guozhang Wang commented on KAFKA-3887: -- The system test still failing but seems in a different way:

[jira] [Reopened] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-3887: -- > StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing >

[jira] [Updated] (KAFKA-3559) Task creation time taking too long in rebalance callback

[ https://issues.apache.org/jira/browse/KAFKA-3559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3559: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-3938 > Task creation time taking too long

[jira] [Updated] (KAFKA-3938) Fix consumer session timeout issue in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-3938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3938: - Labels: architecture (was: ) > Fix consumer session timeout issue in Kafka Streams >

[jira] [Created] (KAFKA-3938) Fix consumer session timeout issue in Kafka Streams

Guozhang Wang created KAFKA-3938: Summary: Fix consumer session timeout issue in Kafka Streams Key: KAFKA-3938 URL: https://issues.apache.org/jira/browse/KAFKA-3938 Project: Kafka Issue

[jira] [Updated] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3758: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-3938 > KStream job fails to recover after

[jira] [Updated] (KAFKA-3752) Provide a way for KStreams to recover from unclean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3752: - Issue Type: Sub-task (was: Improvement) Parent: KAFKA-3938 > Provide a way for KStreams

[jira] [Updated] (KAFKA-3708) Rethink exception handling in KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3708: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-3938 > Rethink exception handling in

[jira] [Resolved] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3887. -- Resolution: Fixed Fix Version/s: 0.10.0.1 Issue resolved by pull request 1597

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366418#comment-15366418 ] Guozhang Wang commented on KAFKA-3101: -- [~bbejeck] Regarding KAFKA-3776, there is still one open

[jira] [Comment Edited] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365365#comment-15365365 ] Guozhang Wang edited comment on KAFKA-3705 at 7/7/16 12:09 AM: --- [~jfilipiak]

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365365#comment-15365365 ] Guozhang Wang commented on KAFKA-3705: -- [~jfilipiak] I am convinced that this combo-key is necessary

[jira] [Resolved] (KAFKA-3926) Transient failures in org.apache.kafka.streams.integration.RegexSourceIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-3926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3926. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1590

[jira] [Resolved] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers

[ https://issues.apache.org/jira/browse/KAFKA-3836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3836. -- Resolution: Fixed Fix Version/s: 0.10.0.1 Issue resolved by pull request 1591

[jira] [Updated] (KAFKA-3836) RocksDBStore.get() should not pass nulls to Deserializers

[ https://issues.apache.org/jira/browse/KAFKA-3836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3836: - Summary: RocksDBStore.get() should not pass nulls to Deserializers (was: KStreamReduce and

[jira] [Updated] (KAFKA-3452) Support session windows besides time interval windows

[ https://issues.apache.org/jira/browse/KAFKA-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3452: - Issue Type: New Feature (was: Sub-task) Parent: (was: KAFKA-2590) > Support session

<    8   9   10   11   12   13   14   15   16   17   >