[jira] [Resolved] (KAFKA-4486) Kafka Streams - exception in process still commits offsets

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

[jira] [Updated] (KAFKA-4393) Improve invalid/negative TS handling

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

[jira] [Updated] (KAFKA-4494) Significant startup delays in KStreams app

[ https://issues.apache.org/jira/browse/KAFKA-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4494: - Component/s: streams > Significant startup delays in KStreams app >

[jira] [Updated] (KAFKA-4494) Significant startup delays in KStreams app

[ https://issues.apache.org/jira/browse/KAFKA-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4494: - Labels: performance (was: ) > Significant startup delays in KStreams app >

[jira] [Created] (KAFKA-4498) Extract Streams section as a separate page from documentation.html

Guozhang Wang created KAFKA-4498: Summary: Extract Streams section as a separate page from documentation.html Key: KAFKA-4498 URL: https://issues.apache.org/jira/browse/KAFKA-4498 Project: Kafka

[jira] [Updated] (KAFKA-4488) UnsupportedOperationException during initialization of StandbyTask

[ https://issues.apache.org/jira/browse/KAFKA-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4488: - Fix Version/s: 0.10.1.1 > UnsupportedOperationException during initialization of StandbyTask >

[jira] [Resolved] (KAFKA-4488) UnsupportedOperationException during initialization of StandbyTask

[ https://issues.apache.org/jira/browse/KAFKA-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4488. -- Resolution: Fixed Fix Version/s: (was: 0.10.1.1) 0.10.2.0 Issue

[jira] [Commented] (KAFKA-4486) Kafka Streams - exception in process still commits offsets

[ https://issues.apache.org/jira/browse/KAFKA-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15723370#comment-15723370 ] Guozhang Wang commented on KAFKA-4486: -- The distinguishment is not in Streams, but in the embedded

[jira] [Updated] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit.

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

[jira] [Commented] (KAFKA-4486) Kafka Streams - exception in process still commits offsets

[ https://issues.apache.org/jira/browse/KAFKA-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721213#comment-15721213 ] Guozhang Wang commented on KAFKA-4486: -- [~joel.lundell] Thanks for reporting your use case, which

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716971#comment-15716971 ] Guozhang Wang commented on KAFKA-4322: -- I think I agree that some app-specific logic during

[jira] [Updated] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage

[ https://issues.apache.org/jira/browse/KAFKA-4484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4484: - Assignee: (was: Henry Cai) > Set more conservative default values on RocksDB for memory usage

[jira] [Commented] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage

[ https://issues.apache.org/jira/browse/KAFKA-4484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716836#comment-15716836 ] Guozhang Wang commented on KAFKA-4484: -- [~h...@pinterest.com] [~flyaruu] do you want to consider

[jira] [Created] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage

Guozhang Wang created KAFKA-4484: Summary: Set more conservative default values on RocksDB for memory usage Key: KAFKA-4484 URL: https://issues.apache.org/jira/browse/KAFKA-4484 Project: Kafka

[jira] [Updated] (KAFKA-4473) RecordCollector should handle retriable exceptions more strictly

[ https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4473: - Labels: architecture (was: ) > RecordCollector should handle retriable exceptions more strictly

[jira] [Updated] (KAFKA-4473) RecordCollector should handle retriable exceptions more strictly

[ https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4473: - Summary: RecordCollector should handle retriable exceptions more strictly (was: KafkaStreams

[jira] [Commented] (KAFKA-4473) KafkaStreams does *not* guarantee at-least-once delivery

[ https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716796#comment-15716796 ] Guozhang Wang commented on KAFKA-4473: -- Thanks for the update [~Thomas Schulz]. I think what you

[jira] [Commented] (KAFKA-4473) KafkaStreams does *not* guarantee at-least-once delivery

[ https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713038#comment-15713038 ] Guozhang Wang commented on KAFKA-4473: -- [~Thomas Schulz] Thanks for reporting this issue. I have a

[jira] [Updated] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

[ https://issues.apache.org/jira/browse/KAFKA-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4461: - Labels: newbie (was: ) > When using ProcessorTopologyTestDriver, the combination of map and >

[jira] [Comment Edited] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712821#comment-15712821 ] Guozhang Wang edited comment on KAFKA-4474 at 12/1/16 7:19 PM: ---

[jira] [Updated] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4474: - Assignee: Eno Thereska > Poor kafka-streams throughput > - > >

[jira] [Commented] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712821#comment-15712821 ] Guozhang Wang commented on KAFKA-4474: -- [~enothereska] Could you take a look and see if there is any

[jira] [Resolved] (KAFKA-4475) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4475. -- Resolution: Duplicate Duplicate of KAFKA-4474. > Poor kafka-streams throughput >

[jira] [Resolved] (KAFKA-4438) BACKPORT - Add scala 2.12 support

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

[jira] [Resolved] (KAFKA-3637) Add method that checks if streams are initialised

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

[jira] [Updated] (KAFKA-4271) The console consumer fails on Windows with new consumer is used

[ https://issues.apache.org/jira/browse/KAFKA-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4271: - Resolution: Fixed Fix Version/s: 0.10.1.1 0.10.2.0 Status:

[jira] [Updated] (KAFKA-4463) Setup travis-ci integration for ducktape tests

[ https://issues.apache.org/jira/browse/KAFKA-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4463: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Setup travis-ci integration for

[jira] [Updated] (KAFKA-4466) Add support to ducktape to run only a part of all tests

[ https://issues.apache.org/jira/browse/KAFKA-4466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4466: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Add support to ducktape to run

[jira] [Updated] (KAFKA-4467) Run tests on travis-ci using docker

[ https://issues.apache.org/jira/browse/KAFKA-4467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4467: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Run tests on travis-ci using

[jira] [Updated] (KAFKA-4465) Create docker image and scripts for running tests locally

[ https://issues.apache.org/jira/browse/KAFKA-4465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4465: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Create docker image and scripts

[jira] [Created] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

Guozhang Wang created KAFKA-4468: Summary: Correctly calculate the window end timestamp after read from state stores Key: KAFKA-4468 URL: https://issues.apache.org/jira/browse/KAFKA-4468 Project:

[jira] [Resolved] (KAFKA-4427) Skip topicGroups with no tasks

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

[jira] [Commented] (KAFKA-4405) Kafka consumer improperly send prefetch request

[ https://issues.apache.org/jira/browse/KAFKA-4405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15706166#comment-15706166 ] Guozhang Wang commented on KAFKA-4405: -- Thanks [~enothereska]. > Kafka consumer improperly send

[jira] [Updated] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt

[ https://issues.apache.org/jira/browse/KAFKA-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4039: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Exit Strategy: using exceptions

[jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt

[ https://issues.apache.org/jira/browse/KAFKA-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15706109#comment-15706109 ] Guozhang Wang commented on KAFKA-4039: -- Discussed offline, we will move this out of 0.10.1.1 as there

[jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt

[ https://issues.apache.org/jira/browse/KAFKA-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703697#comment-15703697 ] Guozhang Wang commented on KAFKA-4039: -- Ping [~hachikuji] [~ijuma] again. > Exit Strategy: using

[jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt

[ https://issues.apache.org/jira/browse/KAFKA-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703696#comment-15703696 ] Guozhang Wang commented on KAFKA-4039: -- Ping [~hachikuji] [~ijuma] again. > Exit Strategy: using

[jira] [Updated] (KAFKA-4399) Deadlock between cleanupGroupMetadata and offset commit

[ https://issues.apache.org/jira/browse/KAFKA-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4399: - Assignee: Alexey Ozeritskiy > Deadlock between cleanupGroupMetadata and offset commit >

[jira] [Commented] (KAFKA-4399) Deadlock between cleanupGroupMetadata and offset commit

[ https://issues.apache.org/jira/browse/KAFKA-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703435#comment-15703435 ] Guozhang Wang commented on KAFKA-4399: -- Ping [~hachikuji] [~ijuma] again. > Deadlock between

[jira] [Commented] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks

[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703349#comment-15703349 ] Guozhang Wang commented on KAFKA-4450: -- [~ewencp] [~ijuma] What's the status of this JIRA ticket? >

[jira] [Updated] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks

[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4450: - Fix Version/s: (was: 0.11.0.0) > Add missing 0.10.1.x upgrade tests and ensure ongoing

[jira] [Commented] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702635#comment-15702635 ] Guozhang Wang commented on KAFKA-4447: -- My two cents here: 1. ZkClient's causing our listener

[jira] [Commented] (KAFKA-4405) Kafka consumer improperly send prefetch request

[ https://issues.apache.org/jira/browse/KAFKA-4405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15701064#comment-15701064 ] Guozhang Wang commented on KAFKA-4405: -- [~enothereska] Maybe this can result in performance

[jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt

[ https://issues.apache.org/jira/browse/KAFKA-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691142#comment-15691142 ] Guozhang Wang commented on KAFKA-4039: -- [~hachikuji] [~ijuma] If you guys feel it is an important fix

[jira] [Commented] (KAFKA-1377) transient unit test failure in LogOffsetTest

[ https://issues.apache.org/jira/browse/KAFKA-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691106#comment-15691106 ] Guozhang Wang commented on KAFKA-1377: -- [~ijuma] Is this still an issue? I cannot remember seeing

[jira] [Updated] (KAFKA-2363) ProducerSendTest.testCloseWithZeroTimeoutFromCallerThread Transient Failure

[ https://issues.apache.org/jira/browse/KAFKA-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2363: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 >

[jira] [Resolved] (KAFKA-1573) Transient test failures on LogTest.testCorruptLog

[ https://issues.apache.org/jira/browse/KAFKA-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1573. -- Resolution: Not A Problem > Transient test failures on LogTest.testCorruptLog >

[jira] [Updated] (KAFKA-3689) Exception when attempting to decrease connection count for address with no connections

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

[jira] [Updated] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3875: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Transient test failure: >

[jira] [Updated] (KAFKA-3986) completedReceives can contain closed channels

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

[jira] [Updated] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value

[ https://issues.apache.org/jira/browse/KAFKA-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3832: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Kafka Connect's JSON Converter

[jira] [Commented] (KAFKA-4178) Replication Throttling: Consolidate Rate Classes

[ https://issues.apache.org/jira/browse/KAFKA-4178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691096#comment-15691096 ] Guozhang Wang commented on KAFKA-4178: -- [~benstopford] [~ijuma] Does it need to be in 0.10.1.1? >

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

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4186. -- Resolution: Not A Problem > Transient failure in

[jira] [Updated] (KAFKA-4340) Change the default value of log.message.timestamp.difference.max.ms to the same as log.retention.ms

[ https://issues.apache.org/jira/browse/KAFKA-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4340: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Change the default value of

[jira] [Updated] (KAFKA-4182) Move the change logger our of RocksDB stores

[ https://issues.apache.org/jira/browse/KAFKA-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4182: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Move the change logger our of

[jira] [Updated] (KAFKA-4184) Test failure in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle

[ https://issues.apache.org/jira/browse/KAFKA-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4184: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Test failure in >

[jira] [Updated] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4401: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > Change the

[jira] [Commented] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message

[ https://issues.apache.org/jira/browse/KAFKA-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691093#comment-15691093 ] Guozhang Wang commented on KAFKA-4384: -- [~junrao] [~ijuma] Do you think it should be in 0.10.1.1? >

[jira] [Commented] (KAFKA-4399) Deadlock between cleanupGroupMetadata and offset commit

[ https://issues.apache.org/jira/browse/KAFKA-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691085#comment-15691085 ] Guozhang Wang commented on KAFKA-4399: -- [~hachikuji] [~ijuma] Do you think it should go in 0.10.1.1?

[jira] [Updated] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks

[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3213: - Fix Version/s: (was: 0.10.1.1) 0.10.2.0 > [CONNECT] It looks like we are

[jira] [Updated] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger

[ https://issues.apache.org/jira/browse/KAFKA-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4379: - Fix Version/s: 0.10.1.1 > Remove caching of dirty and removed keys from StoreChangeLogger >

[jira] [Updated] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted

[ https://issues.apache.org/jira/browse/KAFKA-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4355: - Fix Version/s: 0.10.1.1 > StreamThread intermittently dies with "Topic not found during partition

[jira] [Updated] (KAFKA-4311) Multi layer cache eviction causes forwarding to incorrect ProcessorNode

[ https://issues.apache.org/jira/browse/KAFKA-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4311: - Fix Version/s: 0.10.1.1 > Multi layer cache eviction causes forwarding to incorrect ProcessorNode

[jira] [Updated] (KAFKA-4361) Streams does not respect user configs for "default" params

[ https://issues.apache.org/jira/browse/KAFKA-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4361: - Fix Version/s: 0.10.1.1 > Streams does not respect user configs for "default" params >

[jira] [Updated] (KAFKA-4331) Kafka Streams resetter is slow because it joins the same group for each topic

[ https://issues.apache.org/jira/browse/KAFKA-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4331: - Fix Version/s: 0.10.1.1 > Kafka Streams resetter is slow because it joins the same group for each

[jira] [Updated] (KAFKA-4275) Check of State-Store-assignment to Processor-Nodes is not enabled

[ https://issues.apache.org/jira/browse/KAFKA-4275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4275: - Fix Version/s: (was: 0.10.1.0) 0.10.1.1 > Check of State-Store-assignment

[jira] [Updated] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4269: - Fix Version/s: 0.10.1.1 > Multiple KStream instances with at least one Regex source causes NPE

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

[ https://issues.apache.org/jira/browse/KAFKA-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4352: - Fix Version/s: 0.10.1.1 > Failure in >

[jira] [Updated] (KAFKA-4302) Simplify KTableSource

[ https://issues.apache.org/jira/browse/KAFKA-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4302: - Fix Version/s: 0.10.1.1 > Simplify KTableSource > - > > Key:

[jira] [Comment Edited] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687453#comment-15687453 ] Guozhang Wang edited comment on KAFKA-4322 at 11/22/16 6:09 PM: I see.

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687453#comment-15687453 ] Guozhang Wang commented on KAFKA-4322: -- I see. Just for clarification for "own logging" are you just

[jira] [Commented] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted

[ https://issues.apache.org/jira/browse/KAFKA-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687421#comment-15687421 ] Guozhang Wang commented on KAFKA-4355: -- Resolving the ticket as PR 2133 is merged. [~mihbor] please

[jira] [Resolved] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted

[ https://issues.apache.org/jira/browse/KAFKA-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4355. -- Resolution: Fixed Fix Version/s: 0.10.2.0 > StreamThread intermittently dies with "Topic

[jira] [Commented] (KAFKA-4373) Kafka Consumer API jumping offsets

[ https://issues.apache.org/jira/browse/KAFKA-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15677456#comment-15677456 ] Guozhang Wang commented on KAFKA-4373: -- This may be resulted from the intermediate topic that is

[jira] [Updated] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL

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

[jira] [Updated] (KAFKA-4366) KafkaStreams.close() blocks indefinitely

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

[jira] [Resolved] (KAFKA-4359) Streams integration tests should not use commit interval of 1

[ https://issues.apache.org/jira/browse/KAFKA-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4359. -- Resolution: Fixed Fix Version/s: (was: 0.10.1.1) 0.10.2.0 Issue

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15671093#comment-15671093 ] Guozhang Wang commented on KAFKA-4322: -- Thanks [~markshelton], the reason I mentioned a KIP proposal

[jira] [Commented] (KAFKA-4391) On Windows, Kafka server stops with uncaught exception after coming back from sleep

[ https://issues.apache.org/jira/browse/KAFKA-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15671078#comment-15671078 ] Guozhang Wang commented on KAFKA-4391: -- Currently we do not have plans to release new bug fix

[jira] [Updated] (KAFKA-4346) Add foreachValue method to KStream

[ https://issues.apache.org/jira/browse/KAFKA-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4346: - Assignee: Xavier Léauté > Add foreachValue method to KStream > --

[jira] [Resolved] (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:all-tabpanel ] Guozhang Wang resolved KAFKA-4120. -- Resolution: Fixed Fix Version/s: 0.10.1.0 > byte[] keys in RocksDB state stores do not

[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=15658318#comment-15658318 ] Guozhang Wang commented on KAFKA-4120: -- Marking it as resolved after 0.10.1.0. [~elevy] [~gfodor]

[jira] [Updated] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4212: - Labels: api (was: ) > Add a key-value store that is a TTL persistent cache >

[jira] [Updated] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4212: - Assignee: (was: Guozhang Wang) > Add a key-value store that is a TTL persistent cache >

[jira] [Updated] (KAFKA-4317) RocksDB checkpoint files lost on kill -9

[ https://issues.apache.org/jira/browse/KAFKA-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4317: - Priority: Critical (was: Major) > RocksDB checkpoint files lost on kill -9 >

[jira] [Updated] (KAFKA-4240) Remove disableLogging from API

[ https://issues.apache.org/jira/browse/KAFKA-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4240: - Assignee: (was: Guozhang Wang) > Remove disableLogging from API >

[jira] [Updated] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3522: - Priority: Critical (was: Major) > Consider adding version information into rocksDB storage

[jira] [Updated] (KAFKA-4270) ClassCast for Agregation

[ https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4270: - Labels: architecture (was: ) > ClassCast for Agregation > > >

[jira] [Updated] (KAFKA-4270) ClassCast for Agregation

[ https://issues.apache.org/jira/browse/KAFKA-4270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4270: - Priority: Critical (was: Major) > ClassCast for Agregation > > >

[jira] [Commented] (KAFKA-4281) Should be able to forward aggregation values immediately

[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15658156#comment-15658156 ] Guozhang Wang commented on KAFKA-4281: -- As a hinder-thought of KIP-63, I think it is generally a

[jira] [Updated] (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 updated KAFKA-4219: - Labels: api (was: api user-experience) > Permit setting of event time in stream processor >

[jira] [Updated] (KAFKA-4281) Should be able to forward aggregation values immediately

[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4281: - Assignee: Greg Fodor > Should be able to forward aggregation values immediately >

[jira] [Updated] (KAFKA-4281) Should be able to forward aggregation values immediately

[ https://issues.apache.org/jira/browse/KAFKA-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4281: - Status: Patch Available (was: Open) > Should be able to forward aggregation values immediately >

[jira] [Updated] (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 updated KAFKA-4219: - Labels: api user-experience (was: ) > Permit setting of event time in stream processor >

[jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657841#comment-15657841 ] Guozhang Wang commented on KAFKA-4322: -- [~markshelton] Thanks for proposing this ticket. I read the

[jira] [Updated] (KAFKA-4322) StateRestoreCallback begin and end indication

[ https://issues.apache.org/jira/browse/KAFKA-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4322: - Assignee: Mark Shelton (was: Guozhang Wang) > StateRestoreCallback begin and end indication >

[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=15657814#comment-15657814 ] Guozhang Wang commented on KAFKA-3729: -- [~bharatviswa] are you still working on this issue? >

[jira] [Updated] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger

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

[jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15655234#comment-15655234 ] Guozhang Wang commented on KAFKA-4392: -- [~arae] Here you go:

[jira] [Comment Edited] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15655211#comment-15655211 ] Guozhang Wang edited comment on KAFKA-4392 at 11/10/16 9:34 PM: BTW which

<    6   7   8   9   10   11   12   13   14   15   >