[jira] [Commented] (KAFKA-5677) Remove deprecated punctuate method

[ https://issues.apache.org/jira/browse/KAFKA-5677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107662#comment-16107662 ] Guozhang Wang commented on KAFKA-5677: -- I think we should not remove test coverage as long as the

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

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5676: Assignee: Chanchal Singh > MockStreamsMetrics should be in o.a.k.test >

[jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16107653#comment-16107653 ] Guozhang Wang commented on KAFKA-5233: -- I agree with both of your regarding keeping the unit tests

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111779#comment-16111779 ] Guozhang Wang commented on KAFKA-5684: -- 1. regarding using `peek` to implement `print`: yes we have

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113499#comment-16113499 ] Guozhang Wang commented on KAFKA-5684: -- I have a slightly different idea: 1. Remove the

[jira] [Comment Edited] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113499#comment-16113499 ] Guozhang Wang edited comment on KAFKA-5684 at 8/3/17 9:10 PM: -- I have a

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

[ https://issues.apache.org/jira/browse/KAFKA-5698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5698: Assignee: Guozhang Wang > Sort processor node based on name suffix in

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

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5727: - Fix Version/s: 0.11.0.1 > Add the archetype project along with "write applications" web docs. >

[jira] [Comment Edited] (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=16128011#comment-16128011 ] Guozhang Wang edited comment on KAFKA-5440 at 8/15/17 10:54 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123856#comment-16123856 ] Guozhang Wang commented on KAFKA-5676: -- I think StreamTaskTest#testMetrics does depend on a real

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

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

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16083483#comment-16083483 ] Guozhang Wang commented on KAFKA-1696: -- [~omkreddy] [~singhashish] [~parth.brahmbhatt] Are you still

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16090111#comment-16090111 ] Guozhang Wang commented on KAFKA-5545: -- Hello [~yogeshbelur] sorry for the late reply. I think I

[jira] [Commented] (KAFKA-5578) Streams Task Assignor should consider the staleness of state directories when allocating tasks

[ https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080805#comment-16080805 ] Guozhang Wang commented on KAFKA-5578: -- Hey [~damianguy] do you mean that there could be multiple

[jira] [Commented] (KAFKA-5571) Possible deadlock during shutdown in setState in kafka streams 10.2

[ https://issues.apache.org/jira/browse/KAFKA-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081255#comment-16081255 ] Guozhang Wang commented on KAFKA-5571: -- Is this already fixed in 0.11.0? [~enothereska] [~damianguy]

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5545: - Affects Version/s: 0.10.2.1 > Kafka Stream not able to successfully restart over new broker ip >

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081698#comment-16081698 ] Guozhang Wang commented on KAFKA-5545: -- Thanks for the update. So when you mentioned {code} One more

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

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

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

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

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

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

[jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095565#comment-16095565 ] Guozhang Wang commented on KAFKA-4559: -- Thanks Ravi, I can assign you to this ticket. Also cc'ing

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

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095793#comment-16095793 ] Guozhang Wang commented on KAFKA-4468: -- Even in PAPI, I think today we do not expose APIs for users

[jira] [Commented] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096662#comment-16096662 ] Guozhang Wang commented on KAFKA-3992: -- [~cmolter] There are some discussions about whether we should

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

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

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16098929#comment-16098929 ] Guozhang Wang commented on KAFKA-4750: -- [~evis] That is right, we can go with the first option above.

[jira] [Assigned] (KAFKA-5576) Support Power platform by updating rocksdb

[ https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5576: Assignee: Yussuf Shaikh > Support Power platform by updating rocksdb >

[jira] [Updated] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4601: - Description: Consider the following DSL: {code} Stream source =

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065155#comment-16065155 ] Guozhang Wang commented on KAFKA-4750: -- [~evis] Inside RocksDB store, after the serialization, if we

[jira] [Updated] (KAFKA-5525) Streams reset tool should have same console output with or without dry-run

[ https://issues.apache.org/jira/browse/KAFKA-5525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5525: - Component/s: streams > Streams reset tool should have same console output with or without dry-run

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16075541#comment-16075541 ] Guozhang Wang edited comment on KAFKA-5545 at 7/5/17 10:34 PM: ---

[jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4133: - Fix Version/s: 1.0.0 > Provide a configuration to control consumer max in-flight fetches >

[jira] [Updated] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1696: - Fix Version/s: 1.0.0 > Kafka should be able to generate Hadoop delegation tokens >

[jira] [Updated] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4763: - Fix Version/s: 1.0.0 > Handle disk failure for JBOD (KIP-112) >

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

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

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

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

[jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105814#comment-16105814 ] Guozhang Wang commented on KAFKA-5233: -- [~mihbor] While reviewing some other PRs I realized that

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109435#comment-16109435 ] Guozhang Wang commented on KAFKA-5676: -- If you take a look at all unit test classes that uses,

[jira] [Assigned] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5474: Assignee: Guozhang Wang (was: Matthias J. Sax) > Streams StandbyTask should no checkpoint

[jira] [Assigned] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5474: Assignee: Matthias J. Sax (was: Guozhang Wang) > Streams StandbyTask should no checkpoint

[jira] [Commented] (KAFKA-5711) Bulk Restore Should Handle Deletes

[ https://issues.apache.org/jira/browse/KAFKA-5711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16118753#comment-16118753 ] Guozhang Wang commented on KAFKA-5711: -- [~bbejeck] It sounds like a severe regression introduced in

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117249#comment-16117249 ] Guozhang Wang commented on KAFKA-5676: -- Could you list the test cases that do depend on the

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

[ https://issues.apache.org/jira/browse/KAFKA-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131353#comment-16131353 ] Guozhang Wang commented on KAFKA-5733: -- 3681 contains Bill's PR, so KAFKA-5725 should be unblocked

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

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131417#comment-16131417 ] Guozhang Wang commented on KAFKA-5676: -- Did you follow the pull request procedure to create it? If

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5545: - Fix Version/s: 1.0.0 0.11.0.1 > Kafka Stream not able to successfully restart

[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=16129239#comment-16129239 ] Guozhang Wang commented on KAFKA-5441: -- I'll not do it for 0.11.0.1, moving to 0.11.0.1 / 1.0.0 for

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129204#comment-16129204 ] Guozhang Wang commented on KAFKA-5545: -- [~yogeshbelur] We have KAFKA-5152 which summarizes the root

[jira] [Updated] (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:all-tabpanel ] Guozhang Wang updated KAFKA-5441: - Fix Version/s: (was: 0.11.0.1) 0.11.0.2 1.0.0 > Fix

[jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138)

[ https://issues.apache.org/jira/browse/KAFKA-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129646#comment-16129646 ] Guozhang Wang commented on KAFKA-5233: -- Thanks [~mihbor]! > Changes to punctuate semantics (KIP-138)

[jira] [Updated] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2590: - Fix Version/s: 0.11.0.0 > KIP-28: Kafka Streams Checklist > --- > >

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

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

[jira] [Updated] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3429: - Labels: api (was: api newbie++) > Remove Serdes needed for repartitioning in KTable stateful

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

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

[jira] [Updated] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

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

[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16137146#comment-16137146 ] Guozhang Wang commented on KAFKA-5765: -- Sounds reasonable to me. > Move merge() from StreamsBuilder

[jira] [Updated] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5765: - Fix Version/s: 1.0.0 > Move merge() from StreamsBuilder to KStream >

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130788#comment-16130788 ] Guozhang Wang commented on KAFKA-3856: -- Leaving this JIRA open until we have the doc changes in the

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

[ https://issues.apache.org/jira/browse/KAFKA-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130778#comment-16130778 ] Guozhang Wang commented on KAFKA-5733: -- Yup, moved to 1.0.0 > System tests get exception

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

[ https://issues.apache.org/jira/browse/KAFKA-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5733: Assignee: Bill Bejeck > System tests get exception RocksDBException: db has more levels

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

[ https://issues.apache.org/jira/browse/KAFKA-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5733: - Fix Version/s: (was: 0.11.0.1) 1.0.0 > System tests get exception

[jira] [Commented] (KAFKA-3741) Allow setting of default topic configs via StreamsConfig

[ https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130802#comment-16130802 ] Guozhang Wang commented on KAFKA-3741: -- [~damianguy] Could you update the upgrade guide web doc

[jira] [Commented] (KAFKA-5559) Metrics should throw if two client registers with same ID

[ https://issues.apache.org/jira/browse/KAFKA-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133156#comment-16133156 ] Guozhang Wang commented on KAFKA-5559: -- [~onurkaraman] [~xiaotao183] There are some further

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

[ https://issues.apache.org/jira/browse/KAFKA-5379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061203#comment-16061203 ] Guozhang Wang commented on KAFKA-5379: -- [~twbecker] Could we make a pass over all the Type.CLASS

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4829: Assignee: Guozhang Wang > Improve logging of StreamTask commits >

[jira] [Commented] (KAFKA-4849) Bug in KafkaStreams documentation

[ https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16063739#comment-16063739 ] Guozhang Wang commented on KAFKA-4849: -- We have resolved all the reported issues in this JIRA except

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062384#comment-16062384 ] Guozhang Wang commented on KAFKA-4750: -- I think the Streams library should not assume that either 1)

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

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051118#comment-16051118 ] Guozhang Wang commented on KAFKA-4829: -- We have done some similar thing on the broker side that the

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

[ https://issues.apache.org/jira/browse/KAFKA-5797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5797: - Fix Version/s: 0.11.0.1 > StoreChangelogReader should be resilient to broker-side metadata not

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

Guozhang Wang created KAFKA-5932: Summary: Avoid call fetchPrevious in FlushListeners Key: KAFKA-5932 URL: https://issues.apache.org/jira/browse/KAFKA-5932 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175646#comment-16175646 ] Guozhang Wang commented on KAFKA-5886: -- Thanks for the update. > Introduce delivery.timeout.ms

[jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3554: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

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

[ https://issues.apache.org/jira/browse/KAFKA-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3356: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (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:all-tabpanel ] Guozhang Wang updated KAFKA-4879: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size

[ https://issues.apache.org/jira/browse/KAFKA-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3999: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-5949) User Callback Exceptions need to be handled properly

[ https://issues.apache.org/jira/browse/KAFKA-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5949: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-5185) Adding the RecordMetadata that is returned by the producer to the commitRecord method for SourceTask

[ https://issues.apache.org/jira/browse/KAFKA-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5185: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-3252) compression type for a topic should be used during log compaction

[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3252: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3436: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3190: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-5158) Options for handling exceptions during processing

[ https://issues.apache.org/jira/browse/KAFKA-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5158: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5886: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

[ https://issues.apache.org/jira/browse/KAFKA-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3438: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

[jira] [Updated] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure

[ https://issues.apache.org/jira/browse/KAFKA-5767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5767: - *Reminder to the contributor / reviewer of the PR*: please note that the code deadline for 1.0.0 is

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

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

[jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4133: - Fix Version/s: (was: 1.0.0) 1.1.0 > Provide a configuration to control

[jira] [Updated] (KAFKA-5533) Timestamp-based log compaction

[ https://issues.apache.org/jira/browse/KAFKA-5533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5533: - Fix Version/s: (was: 1.0.0) 1.1.0 > Timestamp-based log compaction >

[jira] [Updated] (KAFKA-5780) Long shutdown time when updated to 0.11.0

[ https://issues.apache.org/jira/browse/KAFKA-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5780: - Fix Version/s: (was: 1.0.0) 1.1.0 > Long shutdown time when updated to

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

[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5520: - Fix Version/s: (was: 1.0.0) 1.1.0 > Extend Consumer Group Reset Offset

[jira] [Updated] (KAFKA-4423) Drop support for Java 7

[ https://issues.apache.org/jira/browse/KAFKA-4423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4423: - Fix Version/s: (was: 1.0.0) 1.1.0 > Drop support for Java 7 >

[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: 1.0.0) 1.1.0 > ChangeLoggingKeyValueByteStore delete

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

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1326: - Fix Version/s: (was: 1.0.0) 1.1.0 > New consumer checklist >

[jira] [Updated] (KAFKA-5527) Idempotent/transactional Producer part 2 (KIP-98)

[ https://issues.apache.org/jira/browse/KAFKA-5527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5527: - Fix Version/s: (was: 1.0.0) 1.1.0 > Idempotent/transactional Producer part

[jira] [Updated] (KAFKA-5482) A CONCURRENT_TRANASCTIONS error for the first AddPartitionsToTxn request slows down transactions significantly

[ https://issues.apache.org/jira/browse/KAFKA-5482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5482: - Fix Version/s: (was: 1.0.0) 1.1.0 > A CONCURRENT_TRANASCTIONS error for

  1   2   3   4   5   6   7   8   9   10   >