[jira] [Resolved] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

2018-01-26 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1482. -- Resolution: Cannot Reproduce Fix Version/s: (was: 1.1.0) > Transient test failures

[jira] [Resolved] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly

2018-01-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6398. -- Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 > Non-aggregation KTable

[jira] [Reopened] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey

2018-01-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4186: -- Assignee: Matthias J. Sax (was: Damian Guy) > Transient failure in

[jira] [Created] (KAFKA-6443) KTable involved in multiple joins could result in duplicate results

2018-01-11 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6443: Summary: KTable involved in multiple joins could result in duplicate results Key: KAFKA-6443 URL: https://issues.apache.org/jira/browse/KAFKA-6443 Project: Kafka

[jira] [Resolved] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start

2018-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6383. -- Resolution: Fixed Issue resolved by pull request 4382

[jira] [Resolved] (KAFKA-6269) KTable state restore fails after rebalance

2018-01-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6269. -- Resolution: Fixed > KTable state restore fails after rebalance >

[jira] [Resolved] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start

2018-01-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6383. -- Resolution: Fixed Fix Version/s: 1.1.0 > StreamThread.shutdown doesn't clean up

[jira] [Resolved] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds

2017-12-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4263. -- Resolution: Fixed Fix Version/s: (was: 0.10.1.1) 1.0.1

[jira] [Created] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient

2017-12-14 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6363: Summary: Use MockAdminClient for any unit tests that depend on AdminClient Key: KAFKA-6363 URL: https://issues.apache.org/jira/browse/KAFKA-6363 Project: Kafka

[jira] [Resolved] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

2017-12-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6360. -- Resolution: Fixed Issue resolved by pull request 4324

[jira] [Resolved] (KAFKA-5156) Options for handling exceptions in streams

2017-12-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5156. -- Resolution: Fixed > Options for handling exceptions in streams >

[jira] [Resolved] (KAFKA-5397) streams are not recovering from LockException during rebalancing

2017-12-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5397. -- Resolution: Fixed > streams are not recovering from LockException during rebalancing >

[jira] [Resolved] (KAFKA-6334) Minor documentation typo

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6334. -- Resolution: Fixed > Minor documentation typo > > >

[jira] [Reopened] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-2319: -- > After controlled shutdown: IllegalStateException: Kafka scheduler has not > been started >

[jira] [Created] (KAFKA-6347) Starting offset breach based log segment deletion never considers active segment

2017-12-11 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6347: Summary: Starting offset breach based log segment deletion never considers active segment Key: KAFKA-6347 URL: https://issues.apache.org/jira/browse/KAFKA-6347

[jira] [Created] (KAFKA-6346) Consolidate multiple background async log operations

2017-12-11 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6346: Summary: Consolidate multiple background async log operations Key: KAFKA-6346 URL: https://issues.apache.org/jira/browse/KAFKA-6346 Project: Kafka Issue

[jira] [Resolved] (KAFKA-1530) howto update continuously

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1530. -- Resolution: Fixed > howto update continuously > - > >

[jira] [Resolved] (KAFKA-1561) Data Loss for Incremented Replica Factor and Leader Election

2017-12-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1561. -- Resolution: Fixed > Data Loss for Incremented Replica Factor and Leader Election >

[jira] [Resolved] (KAFKA-5318) Streams state may be misleading

2017-12-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5318. -- Resolution: Fixed > Streams state may be misleading > --- > >

[jira] [Resolved] (KAFKA-5002) Stream does't seem to consider partitions for processing which are being consumed

2017-12-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5002. -- Resolution: Not A Problem > Stream does't seem to consider partitions for processing which are

[jira] [Resolved] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability

2017-12-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5702. -- Resolution: Fixed > Refactor StreamThread to separate concerns and enable better testability >

[jira] [Created] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

2017-12-08 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6331: Summary: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs Key: KAFKA-6331 URL:

[jira] [Created] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

2017-12-07 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6328: Summary: Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups Key: KAFKA-6328 URL: https://issues.apache.org/jira/browse/KAFKA-6328

[jira] [Resolved] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications

2017-12-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5520. -- Resolution: Fixed Issue resolved by pull request 4159

[jira] [Resolved] (KAFKA-6150) Make Repartition Topics Transient

2017-12-04 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6150. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4270

[jira] [Resolved] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

2017-12-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3502. -- Resolution: Cannot Reproduce > Build is killed during kafka streams tests due to `pure virtual

[jira] [Resolved] (KAFKA-2081) testUncleanLeaderElectionEnabledByTopicOverride transient failure

2017-12-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2081. -- Resolution: Cannot Reproduce > testUncleanLeaderElectionEnabledByTopicOverride transient

[jira] [Resolved] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

2017-12-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1534. -- Resolution: Cannot Reproduce We have not seen this issue any more; closing as not re-produce.

[jira] [Reopened] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

2017-12-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-6078: -- Assignee: (was: Dong Lin) > Investigate failure of

[jira] [Resolved] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials

2017-12-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6118. -- Resolution: Fixed Fix Version/s: 0.11.0.3 1.0.1

[jira] [Reopened] (KAFKA-3508) Transient failure in kafka.security.auth.SimpleAclAuthorizerTest.testHighConcurrencyModificationOfResourceAcls

2017-12-01 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-3508: -- Assignee: (was: Grant Henke) > Transient failure in >

[jira] [Created] (KAFKA-6297) Consumer fetcher should handle UnsupportedVersionException more diligently

2017-12-01 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6297: Summary: Consumer fetcher should handle UnsupportedVersionException more diligently Key: KAFKA-6297 URL: https://issues.apache.org/jira/browse/KAFKA-6297 Project:

[jira] [Created] (KAFKA-6286) Consider reusing materialized store for multi-same-stream join

2017-11-29 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6286: Summary: Consider reusing materialized store for multi-same-stream join Key: KAFKA-6286 URL: https://issues.apache.org/jira/browse/KAFKA-6286 Project: Kafka

[jira] [Resolved] (KAFKA-6038) Repartition topics could be much more transient

2017-11-29 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6038. -- Resolution: Duplicate > Repartition topics could be much more transient >

[jira] [Resolved] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

2017-11-29 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4499. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4258

[jira] [Resolved] (KAFKA-6274) Improve KTable Source state store auto-generated names

2017-11-28 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6274. -- Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Issue resolved by pull

[jira] [Created] (KAFKA-6274) Improve KTable Source state store auto-generated names

2017-11-27 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6274: Summary: Improve KTable Source state store auto-generated names Key: KAFKA-6274 URL: https://issues.apache.org/jira/browse/KAFKA-6274 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6214) Using standby replicas with an in memory state store causes Streams to crash

2017-11-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6214. -- Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Issue resolved by pull

[jira] [Created] (KAFKA-6234) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpoint

2017-11-19 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6234: Summary: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpoint Key: KAFKA-6234 URL: https://issues.apache.org/jira/browse/KAFKA-6234

[jira] [Resolved] (KAFKA-6233) Removed unnecessary null check

2017-11-19 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6233. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4232

[jira] [Resolved] (KAFKA-5254) rethink KTable API overloads

2017-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5254. -- Resolution: Duplicate > rethink KTable API overloads > > >

[jira] [Resolved] (KAFKA-6179) RecordQueue.clear() does not clear MinTimestampTracker's maintained list

2017-11-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6179. -- Resolution: Fixed Fix Version/s: 0.11.0.2 1.1.0

[jira] [Created] (KAFKA-6179) RecordQueue.clear() does not clear MinTimestampTracker's maintained list

2017-11-06 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6179: Summary: RecordQueue.clear() does not clear MinTimestampTracker's maintained list Key: KAFKA-6179 URL: https://issues.apache.org/jira/browse/KAFKA-6179 Project:

[jira] [Resolved] (KAFKA-1326) New consumer checklist

2017-11-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1326. -- Resolution: Fixed > New consumer checklist > -- > > Key:

[jira] [Created] (KAFKA-6170) Add the AdminClient in Streams' KafkaClientSupplier

2017-11-03 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6170: Summary: Add the AdminClient in Streams' KafkaClientSupplier Key: KAFKA-6170 URL: https://issues.apache.org/jira/browse/KAFKA-6170 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6159) Link to upgrade docs in 1.0.0 release notes is broken

2017-11-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6159. -- Resolution: Fixed > Link to upgrade docs in 1.0.0 release notes is broken >

[jira] [Created] (KAFKA-6150) Make Repartition Topics Transient

2017-10-30 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6150: Summary: Make Repartition Topics Transient Key: KAFKA-6150 URL: https://issues.apache.org/jira/browse/KAFKA-6150 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6100) Streams quick start crashes Java on Windows

2017-10-26 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6100. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 4136

[jira] [Created] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials

2017-10-25 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6118: Summary: Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials Key: KAFKA-6118 URL:

[jira] [Resolved] (KAFKA-5140) Flaky ResetIntegrationTest

2017-10-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5140. -- Resolution: Fixed Fix Version/s: (was: 0.11.0.0) 0.11.0.2

[jira] [Created] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

2017-10-23 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6106: Summary: Postpone normal processing of tasks within a thread until restoration of all tasks have completed Key: KAFKA-6106 URL: https://issues.apache.org/jira/browse/KAFKA-6106

[jira] [Created] (KAFKA-6098) Delete and Re-create topic operation could result in race condition

2017-10-20 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6098: Summary: Delete and Re-create topic operation could result in race condition Key: KAFKA-6098 URL: https://issues.apache.org/jira/browse/KAFKA-6098 Project: Kafka

[jira] [Resolved] (KAFKA-6085) Streams rebalancing may cause a first batch of fetched records to be dropped

2017-10-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6085. -- Resolution: Not A Problem Fix Version/s: (was: 1.0.0) This is actually not a bug,

[jira] [Created] (KAFKA-6085) Streams rebalancing may cause a first batch of fetched records to be dropped

2017-10-18 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6085: Summary: Streams rebalancing may cause a first batch of fetched records to be dropped Key: KAFKA-6085 URL: https://issues.apache.org/jira/browse/KAFKA-6085 Project:

[jira] [Created] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6049: Summary: Kafka Streams: Add Cogroup in the DSL Key: KAFKA-6049 URL: https://issues.apache.org/jira/browse/KAFKA-6049 Project: Kafka Issue Type: New Feature

[jira] [Resolved] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5977. -- Resolution: Fixed > Upgrade RocksDB dependency to legally acceptable version >

[jira] [Reopened] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5977: -- > Upgrade RocksDB dependency to legally acceptable version >

[jira] [Reopened] (KAFKA-5140) Flaky ResetIntegrationTest

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5140: -- Assignee: Guozhang Wang (was: Matthias J. Sax) Looking into this issue. > Flaky

[jira] [Created] (KAFKA-6039) Improve TaskAssignor to be more load balanced

2017-10-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6039: Summary: Improve TaskAssignor to be more load balanced Key: KAFKA-6039 URL: https://issues.apache.org/jira/browse/KAFKA-6039 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6038) Repartition topics could be much more transient

2017-10-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6038: Summary: Repartition topics could be much more transient Key: KAFKA-6038 URL: https://issues.apache.org/jira/browse/KAFKA-6038 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6037) Make Sub-topology Parallelism Tunable

2017-10-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6037: Summary: Make Sub-topology Parallelism Tunable Key: KAFKA-6037 URL: https://issues.apache.org/jira/browse/KAFKA-6037 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6036) Enable logical materialization to physical materialization

2017-10-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6036: Summary: Enable logical materialization to physical materialization Key: KAFKA-6036 URL: https://issues.apache.org/jira/browse/KAFKA-6036 Project: Kafka

[jira] [Created] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2017-10-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6035: Summary: Avoid creating changelog topics for state stores that are directly piped to a sink topic Key: KAFKA-6035 URL: https://issues.apache.org/jira/browse/KAFKA-6035

[jira] [Created] (KAFKA-6034) Streams DSL to Processor Topology Translation Improvements

2017-10-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6034: Summary: Streams DSL to Processor Topology Translation Improvements Key: KAFKA-6034 URL: https://issues.apache.org/jira/browse/KAFKA-6034 Project: Kafka

[jira] [Resolved] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11

2017-09-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3356. -- Resolution: Fixed Issue resolved by pull request 3036

[jira] [Resolved] (KAFKA-5862) Remove ZK dependency from Streams reset tool

2017-09-22 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5862. -- Resolution: Fixed Issue resolved by pull request 3927

[jira] [Resolved] (KAFKA-5922) Add SessionWindowedKStream

2017-09-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5922. -- Resolution: Fixed Issue resolved by pull request 3902

[jira] [Created] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners

2017-09-19 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5932: Summary: Avoid call fetchPrevious in FlushListeners Key: KAFKA-5932 URL: https://issues.apache.org/jira/browse/KAFKA-5932 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5918) Fix minor typos and errors in the Kafka Streams turotial

2017-09-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5918. -- Resolution: Fixed Issue resolved by pull request 3883

[jira] [Resolved] (KAFKA-5852) Add filter, filterNot, mapValues and Materialized to KTable

2017-09-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5852. -- Resolution: Fixed Issue resolved by pull request 3807

[jira] [Resolved] (KAFKA-5820) Remove unneeded synchronized keyword in StreamThread

2017-09-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5820. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3777

[jira] [Resolved] (KAFKA-5698) Sort processor node based on name suffix in TopologyDescription.toString()

2017-09-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5698. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3618

[jira] [Created] (KAFKA-5839) Upgrade Guide doc changes for KIP-130

2017-09-05 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5839: Summary: Upgrade Guide doc changes for KIP-130 Key: KAFKA-5839 URL: https://issues.apache.org/jira/browse/KAFKA-5839 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

2017-08-31 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4905. -- Resolution: Not A Problem > StreamPartitionAssignor doesn't respect subscriptions to assign

[jira] [Resolved] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available

2017-08-30 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5797. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3748

[jira] [Resolved] (KAFKA-5379) ProcessorContext.appConfigs() should return parsed/validated values

2017-08-29 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5379. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3455

[jira] [Created] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available

2017-08-26 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5797: Summary: StoreChangelogReader should be resilient to broker-side metadata not available Key: KAFKA-5797 URL: https://issues.apache.org/jira/browse/KAFKA-5797

[jira] [Resolved] (KAFKA-5620) SerializationException in doSend() masks class cast exception

2017-08-26 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5620. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3556

[jira] [Resolved] (KAFKA-4787) KafkaStreams close() is not reentrant

2017-08-25 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4787. -- Resolution: Duplicate > KafkaStreams close() is not reentrant >

[jira] [Resolved] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams

2017-08-25 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3826. -- Resolution: Fixed This is been done as part of KAFKA-5152. > Sampling on throughput / latency

[jira] [Created] (KAFKA-5784) Add a sensor for dropped records in window stores

2017-08-24 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5784: Summary: Add a sensor for dropped records in window stores Key: KAFKA-5784 URL: https://issues.apache.org/jira/browse/KAFKA-5784 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-2590) KIP-28: Kafka Streams Checklist

2017-08-22 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2590. -- Resolution: Fixed Assignee: Guozhang Wang > KIP-28: Kafka Streams Checklist >

[jira] [Resolved] (KAFKA-5733) System tests get exception RocksDBException: db has more levels than options.num_levels

2017-08-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5733. -- Resolution: Fixed Issue resolved by pull request 3681

[jira] [Resolved] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-08-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5545. -- Resolution: Duplicate Duplicated as KAFKA-5152. > Kafka Stream not able to successfully

[jira] [Resolved] (KAFKA-5727) Add the archetype project along with "write applications" web docs.

2017-08-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5727. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3630

[jira] [Created] (KAFKA-5727) Add the archetype project along with "write applications" web docs.

2017-08-11 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5727: Summary: Add the archetype project along with "write applications" web docs. Key: KAFKA-5727 URL: https://issues.apache.org/jira/browse/KAFKA-5727 Project: Kafka

[jira] [Created] (KAFKA-5719) Create a quickstart archetype project for Kafka Streams

2017-08-09 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5719: Summary: Create a quickstart archetype project for Kafka Streams Key: KAFKA-5719 URL: https://issues.apache.org/jira/browse/KAFKA-5719 Project: Kafka Issue

[jira] [Created] (KAFKA-5698) Sort processor node based on name suffix in TopologyDescription.toString()

2017-08-03 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5698: Summary: Sort processor node based on name suffix in TopologyDescription.toString() Key: KAFKA-5698 URL: https://issues.apache.org/jira/browse/KAFKA-5698 Project:

[jira] [Created] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

2017-08-03 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5697: Summary: StreamThread.close() need to interrupt the stream threads to break the loop Key: KAFKA-5697 URL: https://issues.apache.org/jira/browse/KAFKA-5697 Project:

[jira] [Resolved] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

2017-08-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5006. -- Resolution: Fixed Fix Version/s: (was: 0.11.0.1) 1.0.0 Issue

[jira] [Resolved] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder

2017-07-31 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5671. -- Resolution: Fixed Issue resolved by pull request 3602

[jira] [Created] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

2017-07-28 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5676: Summary: MockStreamsMetrics should be in o.a.k.test Key: KAFKA-5676 URL: https://issues.apache.org/jira/browse/KAFKA-5676 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-5363) Add ability to batch restore and receive restoration stats.

2017-07-28 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5363. -- Resolution: Fixed Issue resolved by pull request 3325

[jira] [Reopened] (KAFKA-3856) Cleanup Kafka Streams builder API

2017-07-24 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-3856: -- Leave the JIRA as open since I think there is another PR coming for it. BTW moving forward it's

[jira] [Reopened] (KAFKA-5217) Improve Streams internal exception handling

2017-07-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5217: -- [~enothereska] The parent JIRA is an umbrella story of improving error handling in Streams, while

[jira] [Reopened] (KAFKA-5302) Improve exception handling on streams client (communication with brokers)

2017-07-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5302: -- [~enothereska] Let's leave this ticket open until we have done the migration; also we can use this

[jira] [Reopened] (KAFKA-5301) Improve exception handling on consumer path

2017-07-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5301: -- [~enothereska] I think we should not resolve this JIRA in a hurry. Have you made a thorough pass

[jira] [Created] (KAFKA-5581) Streams can be smarter in deciding when to create changelog topics for state stores

2017-07-10 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-5581: Summary: Streams can be smarter in deciding when to create changelog topics for state stores Key: KAFKA-5581 URL: https://issues.apache.org/jira/browse/KAFKA-5581

[jira] [Resolved] (KAFKA-4829) Improve logging of StreamTask commits

2017-06-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4829. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3354

[jira] [Updated] (KAFKA-5442) Streams producer `client.id` are not unique for EOS

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

<    1   2   3   4   5   6   7   8   9   10   >