[jira] [Resolved] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

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

[jira] [Updated] (KAFKA-3623) Make KStreamTestDriver extending from ExternalResource

[ https://issues.apache.org/jira/browse/KAFKA-3623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3623: - Labels: newbie test (was: test) > Make KStreamTestDriver extending from ExternalResource >

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001376#comment-16001376 ] Guozhang Wang commented on KAFKA-5154: -- [~mjsax] Not sure I understand your last sentence? I do see

[jira] [Commented] (KAFKA-5152) Kafka Streams keeps restoring state after shutdown is initiated during startup

[ https://issues.apache.org/jira/browse/KAFKA-5152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001300#comment-16001300 ] Guozhang Wang commented on KAFKA-5152: -- Thanks [~xvrl] for reporting this issue. I think it is

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001178#comment-16001178 ] Guozhang Wang commented on KAFKA-5070: -- [~dnagarajan] [~shoyebpathan] The WARN entry in your stack

[jira] [Resolved] (KAFKA-5174) RocksDb might stall in environments with 1 core only

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

[jira] [Resolved] (KAFKA-5172) CachingSessionStore doesn't fetchPrevious correctly.

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

[jira] [Assigned] (KAFKA-5172) CachingSessionStore doesn't fetchPrevious correctly.

[ https://issues.apache.org/jira/browse/KAFKA-5172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5172: Assignee: Kyle Winkelman > CachingSessionStore doesn't fetchPrevious correctly. >

[jira] [Resolved] (KAFKA-5143) Windows platform does not offer kafka-broker-api-versions.bat

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

[jira] [Assigned] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-1194: Assignee: (was: Jay Kreps) > The kafka broker cannot delete the old log files after

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15998866#comment-15998866 ] Guozhang Wang commented on KAFKA-1194: -- [~miguno] I am not sure if this issue ever gets resolved

[jira] [Commented] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15998851#comment-15998851 ] Guozhang Wang commented on KAFKA-4743: -- Created 5181 without being aware of this ticket. I think if

[jira] [Created] (KAFKA-5181) Add a new request into admin client to manually setting the committed offsets

Guozhang Wang created KAFKA-5181: Summary: Add a new request into admin client to manually setting the committed offsets Key: KAFKA-5181 URL: https://issues.apache.org/jira/browse/KAFKA-5181 Project:

[jira] [Resolved] (KAFKA-5161) reassign-partitions to check if broker of ID exists in cluster

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

[jira] [Resolved] (KAFKA-5104) DumpLogSegments should not open index files with `rw`

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

[jira] [Resolved] (KAFKA-5118) Improve message for Kafka failed startup with non-Kafka data in data.dirs

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

[jira] [Updated] (KAFKA-4925) Add a configurable delay to the initial consumer group rebalance

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

[jira] [Created] (KAFKA-5171) TC should not accept empty string transactional id

Guozhang Wang created KAFKA-5171: Summary: TC should not accept empty string transactional id Key: KAFKA-5171 URL: https://issues.apache.org/jira/browse/KAFKA-5171 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5045) KTable materialization and improved semantics

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

[jira] [Reopened] (KAFKA-2837) FAILING TEST: kafka.api.ProducerBounceTest > testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-2837: -- Saw this test failure again: {code} kafka.api.ProducerBounceTest > testBrokerFailure FAILED

[jira] [Commented] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15995872#comment-15995872 ] Guozhang Wang commented on KAFKA-4801: -- [~hachikuji] Saw this happen again but with a different stack

[jira] [Updated] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

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

[jira] [Updated] (KAFKA-5144) MinTimestampTracker uses confusing variable names

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

[jira] [Assigned] (KAFKA-5114) Clarify meaning of logs in Introduction: Topics and Logs

[ https://issues.apache.org/jira/browse/KAFKA-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5114: Assignee: (was: Michael Ernest) > Clarify meaning of logs in Introduction: Topics and

[jira] [Assigned] (KAFKA-5114) Clarify meaning of logs in Introduction: Topics and Logs

[ https://issues.apache.org/jira/browse/KAFKA-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5114: Assignee: Michael Ernest > Clarify meaning of logs in Introduction: Topics and Logs >

[jira] [Assigned] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4996: Assignee: Amit Daga > Fix findbugs multithreaded correctness warnings for streams >

[jira] [Reopened] (KAFKA-4583) KafkaConsumerTest.testGracefulClose transient failure

[ https://issues.apache.org/jira/browse/KAFKA-4583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4583: -- Saw this failure again but with a different stack trace:

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993594#comment-15993594 ] Guozhang Wang commented on KAFKA-5154: -- I think I saw a similar issue a days ago and was trying to

[jira] [Assigned] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5055: Assignee: Davor Poldrugo (was: Guozhang Wang) > Kafka Streams skipped-records-rate sensor

[jira] [Commented] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991978#comment-15991978 ] Guozhang Wang commented on KAFKA-5055: -- [~dpoldrugo] Thanks! Added. > Kafka Streams

[jira] [Created] (KAFKA-5151) Refactor TransactionCoordinator in-memory structure and error handling logic

Guozhang Wang created KAFKA-5151: Summary: Refactor TransactionCoordinator in-memory structure and error handling logic Key: KAFKA-5151 URL: https://issues.apache.org/jira/browse/KAFKA-5151 Project:

[jira] [Assigned] (KAFKA-5137) Controlled shutdown timeout message improvement

[ https://issues.apache.org/jira/browse/KAFKA-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5137: Assignee: Umesh Chaudhary > Controlled shutdown timeout message improvement >

[jira] [Updated] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4593: - Description: 1. Assume 2 running threads A and B, and one task t1 jut for simplicity. Thread A

[jira] [Commented] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15988354#comment-15988354 ] Guozhang Wang commented on KAFKA-4593: -- Yeah these two issues are not related, and also I need to

[jira] [Updated] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4593: - Description: 1. Assume 2 running threads A and B, and one task t1 jut for simplicity. 2. First

[jira] [Updated] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store

[ https://issues.apache.org/jira/browse/KAFKA-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4953: - Labels: user-experience (was: ) > Global Store: cast exception when initialising with in-memory

[jira] [Updated] (KAFKA-5005) JoinIntegrationTest fails occasionally

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

[jira] [Reopened] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures

[ https://issues.apache.org/jira/browse/KAFKA-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4801: -- > Transient test failure (part 2): > ConsumerBounceTest.testConsumptionWithBrokerFailures >

[jira] [Resolved] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5122. -- Resolution: Fixed > Kafka Streams unexpected off-heap memory growth >

[jira] [Assigned] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5122: Assignee: Guozhang Wang > Kafka Streams unexpected off-heap memory growth >

[jira] [Comment Edited] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15987806#comment-15987806 ] Guozhang Wang edited comment on KAFKA-5122 at 4/27/17 10:16 PM:

[jira] [Commented] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15987806#comment-15987806 ] Guozhang Wang commented on KAFKA-5122: -- [~jon_fuseelements] Thanks a lots for reporting this! We are

[jira] [Assigned] (KAFKA-5005) JoinIntegrationTest fails occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5005: Assignee: Armin Braun (was: Eno Thereska) > JoinIntegrationTest fails occasionally >

[jira] [Resolved] (KAFKA-5124) shouldInnerLeftJoin unit test fails

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

[jira] [Updated] (KAFKA-5111) Improve internal Task APIs

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

[jira] [Commented] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982386#comment-15982386 ] Guozhang Wang commented on KAFKA-4879: -- [~huxi_2b] adding the timeout in these internal functions

[jira] [Commented] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981662#comment-15981662 ] Guozhang Wang commented on KAFKA-5055: -- Thanks [~nthean], looking into it now. > Kafka Streams

[jira] [Assigned] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5055: Assignee: Guozhang Wang > Kafka Streams skipped-records-rate sensor producing nonzero

[jira] [Resolved] (KAFKA-523) OffsetRequest handler does not handle errors

[ https://issues.apache.org/jira/browse/KAFKA-523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-523. - Resolution: Fixed > OffsetRequest handler does not handle errors >

[jira] [Commented] (KAFKA-523) OffsetRequest handler does not handle errors

[ https://issues.apache.org/jira/browse/KAFKA-523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979526#comment-15979526 ] Guozhang Wang commented on KAFKA-523: - I think this issue has already been fixed in

[jira] [Resolved] (KAFKA-454) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[ https://issues.apache.org/jira/browse/KAFKA-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-454. - Resolution: Won't Fix > ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) >

[jira] [Updated] (KAFKA-617) Refactor KafkaApis.handleListOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-617: Summary: Refactor KafkaApis.handleListOffsetRequest (was: Refactor KafkaApis.handleOffsetRequest)

[jira] [Commented] (KAFKA-617) Refactor KafkaApis.handleOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979524#comment-15979524 ] Guozhang Wang commented on KAFKA-617: - [~jozi-k] I think it has been named to

[jira] [Commented] (KAFKA-454) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[ https://issues.apache.org/jira/browse/KAFKA-454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979525#comment-15979525 ] Guozhang Wang commented on KAFKA-454: - Thanks for pointing out. > ProducerSendThread calls

[jira] [Updated] (KAFKA-5090) Kafka Streams SessionStore.findSessions javadoc broken

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

[jira] [Updated] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15978061#comment-15978061 ] Guozhang Wang commented on KAFKA-5006: -- [~xvrl] That is right. > KeyValueStore.put may throw

[jira] [Updated] (KAFKA-5088) some spelling error in code comment

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

[jira] [Resolved] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4980. -- Resolution: Fixed Fix Version/s: 0.10.2.1 > testReprocessingFromScratch unit test

[jira] [Commented] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977756#comment-15977756 ] Guozhang Wang commented on KAFKA-4980: -- Cherry-picked to 0.10.2 > testReprocessingFromScratch unit

[jira] [Assigned] (KAFKA-4927) KStreamsTestDriver fails with NPE when KStream.to() sinks are used

[ https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4927: Assignee: Wim Van Leuven > KStreamsTestDriver fails with NPE when KStream.to() sinks are

[jira] [Commented] (KAFKA-4927) KStreamsTestDriver fails with NPE when KStream.to() sinks are used

[ https://issues.apache.org/jira/browse/KAFKA-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977724#comment-15977724 ] Guozhang Wang commented on KAFKA-4927: -- [~wimvanleuven] assigning you to this ticket. Moving forward

[jira] [Resolved] (KAFKA-5095) ThreadCacheTest.cacheOverheadsSmallValues fails intermittently

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977593#comment-15977593 ] Guozhang Wang commented on KAFKA-5006: -- [~xvrl] Thanks for reporting the issue. After looking into

[jira] [Updated] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5006: - Labels: user-experience (was: ) > KeyValueStore.put may throw exception unrelated to the current

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

[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977574#comment-15977574 ] Guozhang Wang commented on KAFKA-3502: -- [~enothereska] could you list the details on java / gradle

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

[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-3502: Assignee: (was: Guozhang Wang) > Build is killed during kafka streams tests due to

[jira] [Updated] (KAFKA-5047) NullPointerException while using GlobalKTable in KafkaStreams

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

[jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5037: - Labels: user-experience (was: ) > Infinite loop if all input topics are unknown at startup >

[jira] [Resolved] (KAFKA-4937) Batch resetting offsets in Streams' StoreChangelogReader

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

[jira] [Commented] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975899#comment-15975899 ] Guozhang Wang commented on KAFKA-5055: -- [~nthean] Thanks for reporting this. Could you share your

[jira] [Updated] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5055: - Component/s: streams > Kafka Streams skipped-records-rate sensor producing nonzero values even

[jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4850: - Priority: Major (was: Minor) > RocksDb cannot use Bloom Filters >

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975884#comment-15975884 ] Guozhang Wang commented on KAFKA-4850: -- Bumping up to "major" as this is a critical perf improvement

[jira] [Commented] (KAFKA-4848) Stream thread getting into deadlock state while trying to get rocksdb lock in retryWithBackoff

[ https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975831#comment-15975831 ] Guozhang Wang commented on KAFKA-4848: -- [~sjmittal] It is cherry-picked into 0.10.2 now I think. >

[jira] [Updated] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4996: - Labels: newbie (was: ) > Fix findbugs multithreaded correctness warnings for streams >

[jira] [Updated] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4994: - Labels: newbie (was: ) > Fix findbugs warning about OffsetStorageWriter#currentFlushId >

[jira] [Resolved] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4692. -- Resolution: Cannot Reproduce > Transient test failure in >

[jira] [Commented] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951375#comment-15951375 ] Guozhang Wang commented on KAFKA-4692: -- Thanks [~original-brownbear]!! > Transient test failure in

[jira] [Commented] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951323#comment-15951323 ] Guozhang Wang commented on KAFKA-4692: -- [~original-brownbear] are you trying to re-produce on a Linux

[jira] [Reopened] (KAFKA-4842) Streams integration tests occasionally fail with connection error

[ https://issues.apache.org/jira/browse/KAFKA-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4842: -- Re-open the issue and assigning to [~mjsax] > Streams integration tests occasionally fail with

[jira] [Assigned] (KAFKA-4842) Streams integration tests occasionally fail with connection error

[ https://issues.apache.org/jira/browse/KAFKA-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4842: Assignee: Matthias J. Sax > Streams integration tests occasionally fail with connection

[jira] [Updated] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source

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

[jira] [Updated] (KAFKA-4980) testReprocessingFromScratch unit test failure

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

[jira] [Assigned] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4980: Assignee: Matthias J. Sax > testReprocessingFromScratch unit test failure >

[jira] [Assigned] (KAFKA-4709) Error message from Struct.validate() should include the name of the offending field.

[ https://issues.apache.org/jira/browse/KAFKA-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4709: Assignee: Aegeaner (was: Jeremy Custenborder) > Error message from Struct.validate()

[jira] [Resolved] (KAFKA-4843) Stream round-robin scheduler is inneficient

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

[jira] [Commented] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943852#comment-15943852 ] Guozhang Wang commented on KAFKA-4692: -- Thanks for looking into this [~original-brownbear]! Let me

[jira] [Resolved] (KAFKA-4881) Add internal leave.group.on.close config to consumer

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

[jira] [Created] (KAFKA-4948) Failure in kafka.admin.DescribeConsumerGroupTest.testDescribeExistingGroupWithNoMembersWithNewConsumer

Guozhang Wang created KAFKA-4948: Summary: Failure in kafka.admin.DescribeConsumerGroupTest.testDescribeExistingGroupWithNoMembersWithNewConsumer Key: KAFKA-4948 URL:

[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=15938752#comment-15938752 ] Guozhang Wang commented on KAFKA-4392: -- [~elevy] Could you share your settings (num.threads per

[jira] [Resolved] (KAFKA-4919) Document that stores must not be closed when Processors are closed

[ https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4919. -- Resolution: Fixed Fix Version/s: 0.10.2.1 0.11.0.0 > Document that

[jira] [Created] (KAFKA-4937) Batch resetting offsets in Streams' StoreChangelogReader

Guozhang Wang created KAFKA-4937: Summary: Batch resetting offsets in Streams' StoreChangelogReader Key: KAFKA-4937 URL: https://issues.apache.org/jira/browse/KAFKA-4937 Project: Kafka Issue

[jira] [Resolved] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1]

[ https://issues.apache.org/jira/browse/KAFKA-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4732. -- Resolution: Fixed As part of https://issues.apache.org/jira/browse/KAFKA-4859. > Unstable

[jira] [Commented] (KAFKA-4919) Document that stores must not be closed when Processors are closed

[ https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15936891#comment-15936891 ] Guozhang Wang commented on KAFKA-4919: -- [~elevy] There is a PR open for this ticket but not yet

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935729#comment-15935729 ] Guozhang Wang commented on KAFKA-4890: -- [~yunolgun] Thanks for the updates. I tried to reproduce the

[jira] [Commented] (KAFKA-4848) Stream thread getting into deadlock state while trying to get rocksdb lock in retryWithBackoff

[ https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935696#comment-15935696 ] Guozhang Wang commented on KAFKA-4848: -- [~sjmittal] Could I ask you a follow-up question: are these

[jira] [Commented] (KAFKA-4919) Streams job fails with InvalidStateStoreException: Store is currently closed

[ https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15935663#comment-15935663 ] Guozhang Wang commented on KAFKA-4919: -- [~damianguy] Could you take a look? > Streams job fails with

[jira] [Updated] (KAFKA-4929) Transformation Key/Value type references should be to class name(), not canonicalName()

[ https://issues.apache.org/jira/browse/KAFKA-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4929: - Component/s: KafkaConnect > Transformation Key/Value type references should be to class name(),

<    3   4   5   6   7   8   9   10   11   12   >