[jira] [Updated] (KAFKA-5446) Annoying braces showed on log.error using streams

[ https://issues.apache.org/jira/browse/KAFKA-5446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5446: - Affects Version/s: 0.11.0.0 > Annoying braces showed on log.error using streams >

[jira] [Assigned] (KAFKA-5446) Annoying braces showed on log.error using streams

[ https://issues.apache.org/jira/browse/KAFKA-5446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5446: Assignee: Paolo Patierno > Annoying braces showed on log.error using streams >

[jira] [Commented] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead

[ https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049574#comment-16049574 ] Guozhang Wang commented on KAFKA-5440: -- This is a good find, and maybe it is related to some

[jira] [Commented] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049515#comment-16049515 ] Guozhang Wang commented on KAFKA-5245: -- Anyways [~evis] I have added you to the contributor list,

[jira] [Commented] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049511#comment-16049511 ] Guozhang Wang commented on KAFKA-5245: -- Here is my take on the serde issues: We currently follow

[jira] [Commented] (KAFKA-5441) Fix transaction marker grouping by producerId in TC

[ https://issues.apache.org/jira/browse/KAFKA-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049349#comment-16049349 ] Guozhang Wang commented on KAFKA-5441: -- I see it is not a blocker for 0.11.0.0, but I can still take

[jira] [Commented] (KAFKA-4857) Use AdminClient in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16046763#comment-16046763 ] Guozhang Wang commented on KAFKA-4857: -- I think it will not be included in the 0.11.0 release as

[jira] [Resolved] (KAFKA-4661) Improve test coverage UsePreviousTimeOnInvalidTimestamp

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

[jira] [Comment Edited] (KAFKA-5415) TransactionCoordinator doesn't complete transition to PrepareCommit state

[ https://issues.apache.org/jira/browse/KAFKA-5415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16044885#comment-16044885 ] Guozhang Wang edited comment on KAFKA-5415 at 6/9/17 11:28 PM: --- [~apurva]

[jira] [Comment Edited] (KAFKA-5415) TransactionCoordinator doesn't complete transition to PrepareCommit state

[ https://issues.apache.org/jira/browse/KAFKA-5415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16044885#comment-16044885 ] Guozhang Wang edited comment on KAFKA-5415 at 6/9/17 10:59 PM: --- [~apurva]

[jira] [Commented] (KAFKA-5415) TransactionCoordinator gets stuck in PrepareCommit state

[ https://issues.apache.org/jira/browse/KAFKA-5415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16044885#comment-16044885 ] Guozhang Wang commented on KAFKA-5415: -- [~apurva] [~hachikuji] The root cause is in a couple folds:

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043528#comment-16043528 ] Guozhang Wang commented on KAFKA-4628: -- [~dminkovsky] Thanks for sharing your use cases. We are

[jira] [Resolved] (KAFKA-5362) Add EOS system tests for Streams API

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

[jira] [Resolved] (KAFKA-5314) Improve exception handling for state stores

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

[jira] [Resolved] (KAFKA-5357) StackOverFlow error in transaction coordinator

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

[jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

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

[jira] [Commented] (KAFKA-4325) Improve processing of late records for window operations

[ https://issues.apache.org/jira/browse/KAFKA-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16036512#comment-16036512 ] Guozhang Wang commented on KAFKA-4325: -- I think the timestamp computation needs some further

[jira] [Updated] (KAFKA-4913) creating a window store with one segment throws division by zero error

[ https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4913: - Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > creating a window store with one

[jira] [Commented] (KAFKA-5368) Kafka Streams skipped-records-rate sensor produces nonzero values when the timestamps are valid

[ https://issues.apache.org/jira/browse/KAFKA-5368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16035429#comment-16035429 ] Guozhang Wang commented on KAFKA-5368: -- Sounds good to me. Maybe we can add one in

[jira] [Updated] (KAFKA-3982) Issue with processing order of consumer properties in console consumer

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

[jira] [Resolved] (KAFKA-5368) Kafka Streams skipped-records-rate sensor produces nonzero values when the timestamps are valid

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

[jira] [Resolved] (KAFKA-5327) Console Consumer should only poll for up to max messages

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

[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=16033636#comment-16033636 ] Guozhang Wang commented on KAFKA-5154: -- [~Lukas Gemela] We have found the root cause, which is is a

[jira] [Resolved] (KAFKA-5361) Add EOS integration tests for Streams API

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

[jira] [Updated] (KAFKA-5351) Broker clean bounce test puts the broker into a 'CONCURRENT_TRANSACTIONS' state permanently

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

[jira] [Commented] (KAFKA-1595) Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount

[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16032478#comment-16032478 ] Guozhang Wang commented on KAFKA-1595: -- Sounds great. If [~ijuma] is fine with it feel free to fork

[jira] [Commented] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16032345#comment-16032345 ] Guozhang Wang commented on KAFKA-5226: -- [~ian.springer] The fix has just been merged into trunk and

[jira] [Updated] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

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

[jira] [Resolved] (KAFKA-5350) Modify Unstable annotations in Streams API

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

[jira] [Updated] (KAFKA-5218) New Short serializer, deserializer, serde

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

[jira] [Commented] (KAFKA-2526) Console Producer / Consumer's serde config is not working

[ https://issues.apache.org/jira/browse/KAFKA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031849#comment-16031849 ] Guozhang Wang commented on KAFKA-2526: -- [~huxi_2b] are you picking this up? > Console Producer /

[jira] [Commented] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031598#comment-16031598 ] Guozhang Wang commented on KAFKA-4064: -- [~ijuma] I will update the fix version. > Add support for

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4064: - Fix Version/s: (was: 0.11.0.0) 0.11.1.0 > Add support for infinite

[jira] [Assigned] (KAFKA-5319) Add a tool to make cluster replica and leader balance

[ https://issues.apache.org/jira/browse/KAFKA-5319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5319: Assignee: Ma Tianchi > Add a tool to make cluster replica and leader balance >

[jira] [Updated] (KAFKA-5308) TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMarker response

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

[jira] [Resolved] (KAFKA-5334) rocksdb.config.setter must be a class instance, not a class name

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

[jira] [Created] (KAFKA-5350) Modify Unstable annotations in Streams API

Guozhang Wang created KAFKA-5350: Summary: Modify Unstable annotations in Streams API Key: KAFKA-5350 URL: https://issues.apache.org/jira/browse/KAFKA-5350 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5332) When resize the index file, maybe caused the content disappear

[ https://issues.apache.org/jira/browse/KAFKA-5332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030120#comment-16030120 ] Guozhang Wang commented on KAFKA-5332: -- Does look like a bug, [~junrao] could you take a look at the

[jira] [Resolved] (KAFKA-4603) the argument of shell in doc wrong and command parsed error

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

[jira] [Resolved] (KAFKA-5278) kafka-console-consumer: `--value-deserializer` is not working but `--property value.deserializer` does

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

[jira] [Updated] (KAFKA-5338) There is a Misspell in ResetIntegrationTest

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

[jira] [Assigned] (KAFKA-5338) There is a Misspell in ResetIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5338: Assignee: hejiefang > There is a Misspell in ResetIntegrationTest >

[jira] [Commented] (KAFKA-5211) KafkaConsumer should not skip a corrupted record after throwing an exception.

[ https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026977#comment-16026977 ] Guozhang Wang commented on KAFKA-5211: -- For this specific issue, Streams should be independent of

[jira] [Updated] (KAFKA-5191) Autogenerate Consumer Fetcher metrics

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

[jira] [Updated] (KAFKA-4660) Improve test coverage KafkaStreams

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

[jira] [Updated] (KAFKA-5309) Stores not queryable after one thread died

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

[jira] [Commented] (KAFKA-5322) Resolve AddPartitions response error code inconsistency

[ https://issues.apache.org/jira/browse/KAFKA-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026481#comment-16026481 ] Guozhang Wang commented on KAFKA-5322: -- [~hachikuji] I'd prefer option 2, to still have a

[jira] [Updated] (KAFKA-5279) TransactionCoordinator must expire transactionalIds

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

[jira] [Updated] (KAFKA-5273) KafkaConsumer.committed() should get latest committed offsets from the server

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

[jira] [Updated] (KAFKA-5280) Protect concurrent access to the cached transaction status

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

[jira] [Assigned] (KAFKA-5311) Support ExtendedDeserializer in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5311: Assignee: Dale Peakall > Support ExtendedDeserializer in Kafka Streams >

[jira] [Commented] (KAFKA-5218) New Short serializer, deserializer, serde

[ https://issues.apache.org/jira/browse/KAFKA-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020477#comment-16020477 ] Guozhang Wang commented on KAFKA-5218: -- Done. > New Short serializer, deserializer, serde >

[jira] [Assigned] (KAFKA-5218) New Short serializer, deserializer, serde

[ https://issues.apache.org/jira/browse/KAFKA-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5218: Assignee: Mario Molina > New Short serializer, deserializer, serde >

[jira] [Updated] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5063: - Labels: unit-test (was: ) > Flaky >

[jira] [Updated] (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 updated KAFKA-3502: - Component/s: streams > Build is killed during kafka streams tests due to `pure virtual method >

[jira] [Updated] (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 updated KAFKA-3502: - Component/s: unit tests > Build is killed during kafka streams tests due to `pure virtual method

[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=16019117#comment-16019117 ] Guozhang Wang commented on KAFKA-3502: -- Have not seen this happen again since KAFKA-5198 is merged,

[jira] [Updated] (KAFKA-5285) optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5285: - Labels: performance (was: ) > optimize upper / lower byte range for key range scan on windowed

[jira] [Resolved] (KAFKA-5192) Range Scan for Windowed State Stores

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

[jira] [Assigned] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-3596: Assignee: (was: Guozhang Wang) > Kafka Streams: Window expiration needs to consider

[jira] [Assigned] (KAFKA-4325) Improve processing of late records for window operations

[ https://issues.apache.org/jira/browse/KAFKA-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4325: Assignee: (was: Guozhang Wang) > Improve processing of late records for window

[jira] [Assigned] (KAFKA-5279) TransactionCoordinator must expire transactionalIds

[ https://issues.apache.org/jira/browse/KAFKA-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5279: Assignee: Guozhang Wang > TransactionCoordinator must expire transactionalIds >

[jira] [Updated] (KAFKA-5260) Producer should not send AbortTxn unless transaction has actually begun

[ https://issues.apache.org/jira/browse/KAFKA-5260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5260: - Labels: exactly-once (was: ) > Producer should not send AbortTxn unless transaction has actually

[jira] [Updated] (KAFKA-5033) Reconsider default retries for idempotent producer

[ https://issues.apache.org/jira/browse/KAFKA-5033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5033: - Labels: exactly-once (was: ) > Reconsider default retries for idempotent producer >

[jira] [Updated] (KAFKA-5031) Additional validation in validateMessagesAndAssignOffsets

[ https://issues.apache.org/jira/browse/KAFKA-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5031: - Labels: exactly-once (was: ) > Additional validation in validateMessagesAndAssignOffsets >

[jira] [Updated] (KAFKA-5210) Application Reset Tool does not need to seek for internal topics

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

[jira] [Resolved] (KAFKA-5231) TransactinoCoordinator does not bump epoch when aborting open transactions

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

[jira] [Resolved] (KAFKA-4772) Exploit #peek to implement #print() and other methods

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

[jira] [Updated] (KAFKA-4923) Add Exactly-Once Semantics to Streams

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

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013159#comment-16013159 ] Guozhang Wang commented on KAFKA-5256: -- Thanks for the explanation. I agree that ideally we should

[jira] [Updated] (KAFKA-5166) Add option "dry run" to Streams application reset tool

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

[jira] [Updated] (KAFKA-5241) GlobalKTable does not checkpoint offsets after restoring state

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012726#comment-16012726 ] Guozhang Wang commented on KAFKA-5151: -- Fixed as part of KAFKA-5130 > Refactor

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

[ https://issues.apache.org/jira/browse/KAFKA-5151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5151. -- Resolution: Fixed Fix Version/s: 0.11.0.0 > Refactor TransactionCoordinator in-memory

[jira] [Commented] (KAFKA-5241) GlobalKTable does not checkpoint offsets after restoring state

[ https://issues.apache.org/jira/browse/KAFKA-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012722#comment-16012722 ] Guozhang Wang commented on KAFKA-5241: -- [~twbecker] Added you to the contributor list and assigned

[jira] [Assigned] (KAFKA-5241) GlobalKTable does not checkpoint offsets after restoring state

[ https://issues.apache.org/jira/browse/KAFKA-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5241: Assignee: Tommy Becker > GlobalKTable does not checkpoint offsets after restoring state >

[jira] [Commented] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012717#comment-16012717 ] Guozhang Wang commented on KAFKA-5256: -- [~twbecker] Thanks for reporting this. Could you elaborate a

[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=16011594#comment-16011594 ] Guozhang Wang commented on KAFKA-5154: -- Also if it is possible could you apply the latest patch from

[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=16011562#comment-16011562 ] Guozhang Wang commented on KAFKA-5154: -- [~Lukas Gemela] Could you upload the full log as well? We

[jira] [Resolved] (KAFKA-5205) CachingSessionStore doesn't use the default keySerde.

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

[jira] [Resolved] (KAFKA-5206) RocksDBSessionStore doesn't use default aggSerde.

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5154: Assignee: Matthias J. Sax > Kafka Streams throws NPE during rebalance >

[jira] [Commented] (KAFKA-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010813#comment-16010813 ] Guozhang Wang commented on KAFKA-3514: -- Thanks [~mihbor] > Stream timestamp computation needs some

[jira] [Commented] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

[ https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010005#comment-16010005 ] Guozhang Wang commented on KAFKA-4273: -- [~vinubarro] I'm wondering if your use case can be handled by

[jira] [Updated] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4563: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-5156 > State transitions error

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

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5156: - Labels: user-experience (was: ) > Options for handling exceptions in streams >

[jira] [Updated] (KAFKA-5157) Options for handling corrupt data during deserialization

[ https://issues.apache.org/jira/browse/KAFKA-5157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5157: - Labels: user-experience (was: ) > Options for handling corrupt data during deserialization >

[jira] [Updated] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

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

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16009155#comment-16009155 ] Guozhang Wang commented on KAFKA-5167: -- Merged https://github.com/apache/kafka/pull/3001 to 0.10.2

[jira] [Updated] (KAFKA-4144) Allow per stream/table timestamp extractor

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

[jira] [Resolved] (KAFKA-5198) RocksDbStore#openIterators should be synchronized, since it is accessed from multiple threads

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

[jira] [Updated] (KAFKA-5216) Cached Session/Window store may return error on iterator.peekNextKey()

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

[jira] [Assigned] (KAFKA-5130) Change InterBrokerSendThread to use a Queue per broker

[ https://issues.apache.org/jira/browse/KAFKA-5130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5130: Assignee: Guozhang Wang > Change InterBrokerSendThread to use a Queue per broker >

[jira] [Resolved] (KAFKA-5130) Change InterBrokerSendThread to use a Queue per broker

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

[jira] [Updated] (KAFKA-5132) Abort long running transactions

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

[jira] [Updated] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

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

[jira] [Created] (KAFKA-5209) Transient failure: kafka.server.MetadataRequestTest.testControllerId

Guozhang Wang created KAFKA-5209: Summary: Transient failure: kafka.server.MetadataRequestTest.testControllerId Key: KAFKA-5209 URL: https://issues.apache.org/jira/browse/KAFKA-5209 Project: Kafka

[jira] [Resolved] (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 resolved KAFKA-4927. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2716

[jira] [Created] (KAFKA-5208) Transient failure: kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe

Guozhang Wang created KAFKA-5208: Summary: Transient failure: kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Key: KAFKA-5208 URL:

[jira] [Updated] (KAFKA-5126) Implement KIP-98 transactional methods in the MockProducer

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

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