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

[jira] [Resolved] (KAFKA-7103) Use bulkloading for RocksDBSegmentedBytesStore during init

[ https://issues.apache.org/jira/browse/KAFKA-7103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7103. -- Resolution: Fixed Fix Version/s: 2.1.0 > Use bulkloading for RocksDBSegmentedBytesStore

[jira] [Resolved] (KAFKA-7136) PushHttpMetricsReporter may deadlock when processing metrics changes

[ https://issues.apache.org/jira/browse/KAFKA-7136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7136. -- Resolution: Fixed Fix Version/s: 1.1.1 > PushHttpMetricsReporter may deadlock when

[jira] [Resolved] (KAFKA-7101) Session Window store should set topic policy `compact,cleanup`

[ https://issues.apache.org/jira/browse/KAFKA-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7101. -- Resolution: Fixed Fix Version/s: 2.1.0 > Session Window store should set topic policy

[jira] [Resolved] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6986. -- Resolution: Fixed Fix Version/s: 2.1.0 > Export Admin Client metrics through Stream

[jira] [Resolved] (KAFKA-7097) VerifiableProducer does not work properly with --message-create-time argument

[ https://issues.apache.org/jira/browse/KAFKA-7097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7097. -- Resolution: Fixed Assignee: Ted Yu Reviewer: Guozhang Wang Fix

[jira] [Created] (KAFKA-7112) StreamThread does not check for state again after pollRequests()

Guozhang Wang created KAFKA-7112: Summary: StreamThread does not check for state again after pollRequests() Key: KAFKA-7112 URL: https://issues.apache.org/jira/browse/KAFKA-7112 Project: Kafka

[jira] [Resolved] (KAFKA-7072) Kafka Streams may drop rocksb window segments before they expire

[ https://issues.apache.org/jira/browse/KAFKA-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7072. -- Resolution: Fixed > Kafka Streams may drop rocksb window segments before they expire >

[jira] [Created] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

Guozhang Wang created KAFKA-7075: Summary: Allow Topology#addGlobalStore to add a window store Key: KAFKA-7075 URL: https://issues.apache.org/jira/browse/KAFKA-7075 Project: Kafka Issue

[jira] [Resolved] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception

[ https://issues.apache.org/jira/browse/KAFKA-7066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7066. -- Resolution: Fixed > Make Streams Runtime Error User Friendly in Case of Serialisation

[jira] [Resolved] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter

[ https://issues.apache.org/jira/browse/KAFKA-7023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7023. -- Resolution: Fixed Fix Version/s: 2.0.0 > Kafka Streams RocksDB bulk loading config may

[jira] [Resolved] (KAFKA-7021) Source KTable checkpoint is not correct

[ https://issues.apache.org/jira/browse/KAFKA-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7021. -- Resolution: Fixed > Source KTable checkpoint is not correct >

[jira] [Created] (KAFKA-7042) Fall back to the old behavior when the broker is too old to recognize LIST_OFFSET versions

Guozhang Wang created KAFKA-7042: Summary: Fall back to the old behavior when the broker is too old to recognize LIST_OFFSET versions Key: KAFKA-7042 URL: https://issues.apache.org/jira/browse/KAFKA-7042

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

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

[jira] [Resolved] (KAFKA-6993) Fix defective documentations for KStream/KTable methods

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

[jira] [Resolved] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5632. -- Resolution: Duplicate > Message headers not supported by Kafka Streams >

[jira] [Resolved] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API

[ https://issues.apache.org/jira/browse/KAFKA-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6938. -- Resolution: Fixed > Add documentation for accessing Headers on Kafka Streams Processor API >

[jira] [Created] (KAFKA-6989) Support Async Processing in Streams

Guozhang Wang created KAFKA-6989: Summary: Support Async Processing in Streams Key: KAFKA-6989 URL: https://issues.apache.org/jira/browse/KAFKA-6989 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time.

[ https://issues.apache.org/jira/browse/KAFKA-6092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6092. -- Resolution: Fixed Have double checked the docs for coming 2.0 which is clear on the types of

[jira] [Resolved] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies

[ https://issues.apache.org/jira/browse/KAFKA-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6355. -- Resolution: Cannot Reproduce Have not seen this issue for a while, closing for now. >

[jira] [Resolved] (KAFKA-5739) Rewrite KStreamPeekTest at processor level avoiding driver usage

[ https://issues.apache.org/jira/browse/KAFKA-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5739. -- Resolution: Fixed Fix Version/s: 2.0.0 This is already fixed in trunk, coming in 2.0.0

[jira] [Resolved] (KAFKA-5058) Add a sensor to KafkaStreams to track records that have been dropped due to having a null key

[ https://issues.apache.org/jira/browse/KAFKA-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5058. -- Resolution: Fixed Assignee: John Roesler Fix Version/s: 2.0.0 This has been

[jira] [Resolved] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5618. -- Resolution: Cannot Reproduce > Kafka stream not receive any topic/partitions/records info >

[jira] [Resolved] (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 resolved KAFKA-3429. -- Resolution: Fixed With the new API in KIP-182 this is already resolved: the serdes will be

[jira] [Resolved] (KAFKA-5974) Removed unused parameter ProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5974. -- Resolution: Fixed Fix Version/s: 2.0.0 This has been resolved in 2.0 release. >

[jira] [Resolved] (KAFKA-4960) Invalid state store exception

[ https://issues.apache.org/jira/browse/KAFKA-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4960. -- Resolution: Cannot Reproduce > Invalid state store exception > - >

[jira] [Resolved] (KAFKA-6925) Memory leak in org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl

[ https://issues.apache.org/jira/browse/KAFKA-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6925. -- Resolution: Fixed > Memory leak in >

[jira] [Resolved] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate

[ https://issues.apache.org/jira/browse/KAFKA-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6936. -- Resolution: Fixed Fix Version/s: 2.0.0 > Scala API Wrapper for Streams uses default

[jira] [Resolved] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

[ https://issues.apache.org/jira/browse/KAFKA-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6957. -- Resolution: Fixed Fix Version/s: 2.0.0 > Add getter to AbstractStream class to make

[jira] [Resolved] (KAFKA-6924) Making state store queryable on replicas

[ https://issues.apache.org/jira/browse/KAFKA-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6924. -- Resolution: Duplicate > Making state store queryable on replicas >

[jira] [Created] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager

Guozhang Wang created KAFKA-6928: Summary: StreamsPartitionAssignor is double retrying within InternalTopicManager Key: KAFKA-6928 URL: https://issues.apache.org/jira/browse/KAFKA-6928 Project: Kafka

[jira] [Created] (KAFKA-6922) Rethink WindowedStreamPartitioner configurations

Guozhang Wang created KAFKA-6922: Summary: Rethink WindowedStreamPartitioner configurations Key: KAFKA-6922 URL: https://issues.apache.org/jira/browse/KAFKA-6922 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6849) Add transformValues() method to KTable

[ https://issues.apache.org/jira/browse/KAFKA-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6849. -- Resolution: Fixed Fix Version/s: 2.0.0 > Add transformValues() method to KTable >

[jira] [Resolved] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6729. -- Resolution: Fixed > KTable should use user source topics if possible and not create changelog

[jira] [Resolved] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6905. -- Resolution: Fixed Fix Version/s: 2.0.0 > Document that Processor objects can be reused >

[jira] [Resolved] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6896. -- Resolution: Fixed > add producer metrics exporting in KafkaStreams.java >

[jira] [Created] (KAFKA-6903) Improve KTable's sending old value behavior

Guozhang Wang created KAFKA-6903: Summary: Improve KTable's sending old value behavior Key: KAFKA-6903 URL: https://issues.apache.org/jira/browse/KAFKA-6903 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6813. -- Resolution: Fixed > Remove deprecated APIs from KIP-120 and KIP-182 in Streams >

[jira] [Resolved] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool

[ https://issues.apache.org/jira/browse/KAFKA-5965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5965. -- Resolution: Fixed Fix Version/s: 2.0.0 > Remove Deprecated AdminClient from Streams

[jira] [Resolved] (KAFKA-6894) Improve error message when connecting processor with a global store

[ https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6894. -- Resolution: Fixed Fix Version/s: 2.0.0 > Improve error message when connecting processor

[jira] [Resolved] (KAFKA-6878) NPE when querying global state store not in READY state

[ https://issues.apache.org/jira/browse/KAFKA-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6878. -- Resolution: Fixed Fix Version/s: 1.1.1 2.0.0 > NPE when querying

[jira] [Resolved] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals.

[ https://issues.apache.org/jira/browse/KAFKA-6673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6673. -- Resolution: Fixed Fix Version/s: 2.0.0 > Segment and Stamped implement Comparable, but

[jira] [Resolved] (KAFKA-6628) RocksDBSegmentedBytesStoreTest does not cover time window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6628. -- Resolution: Fixed Fix Version/s: 2.0.0 > RocksDBSegmentedBytesStoreTest does not cover

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

[ https://issues.apache.org/jira/browse/KAFKA-5677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5677. -- Resolution: Fixed Assignee: (was: Jimin Hsieh) Fix Version/s: 2.0.0 >

[jira] [Resolved] (KAFKA-6861) Missing ')' in Kafka Streams documentation

[ https://issues.apache.org/jira/browse/KAFKA-6861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6861. -- Resolution: Fixed > Missing ')' in Kafka Streams documentation >

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

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

[jira] [Resolved] (KAFKA-6826) Avoid range scans when forwarding values in window store aggregations

[ https://issues.apache.org/jira/browse/KAFKA-6826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6826. -- Resolution: Fixed Fix Version/s: 2.0.0 > Avoid range scans when forwarding values in

[jira] [Created] (KAFKA-6820) Improve on StreamsMetrics Public APIs

Guozhang Wang created KAFKA-6820: Summary: Improve on StreamsMetrics Public APIs Key: KAFKA-6820 URL: https://issues.apache.org/jira/browse/KAFKA-6820 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6819) Refactor build-in StreamsMetrics internal implementations

Guozhang Wang created KAFKA-6819: Summary: Refactor build-in StreamsMetrics internal implementations Key: KAFKA-6819 URL: https://issues.apache.org/jira/browse/KAFKA-6819 Project: Kafka

[jira] [Resolved] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

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

[jira] [Resolved] (KAFKA-6376) Improve Streams metrics for skipped records

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

[jira] [Resolved] (KAFKA-6815) "default.production.exception.handler" default value is not specified correctly in KafkaStream doc

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

[jira] [Created] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

Guozhang Wang created KAFKA-6813: Summary: Remove deprecated APIs from KIP-120 and KIP-182 in Streams Key: KAFKA-6813 URL: https://issues.apache.org/jira/browse/KAFKA-6813 Project: Kafka

[jira] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6592. -- Resolution: Fixed Thanks for the reminder! > NullPointerException thrown when executing

[jira] [Resolved] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

[ https://issues.apache.org/jira/browse/KAFKA-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6775. -- Resolution: Fixed Fix Version/s: 1.2.0 > AbstractProcessor created in SimpleBenchmark

[jira] [Created] (KAFKA-6803) Caching is turned off for stream-stream Join

Guozhang Wang created KAFKA-6803: Summary: Caching is turned off for stream-stream Join Key: KAFKA-6803 URL: https://issues.apache.org/jira/browse/KAFKA-6803 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-4327) Move Reset Tool from core to streams

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4327. -- Resolution: Won't Fix I'm resolving this ticket as won't fix for now. > Move Reset Tool from

[jira] [Resolved] (KAFKA-6792) Wrong pointer in the link for stream dsl

[ https://issues.apache.org/jira/browse/KAFKA-6792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6792. -- Resolution: Fixed Fix Version/s: 1.0.0 > Wrong pointer in the link for stream dsl >

[jira] [Resolved] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6058. -- Resolution: Fixed > KIP-222: Add "describe consumer groups" and "list consumer groups" to >

[jira] [Resolved] (KAFKA-6790) Broken link in documentation for processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-6790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6790. -- Resolution: Fixed Fix Version/s: 1.1.0 > Broken link in documentation for processor

[jira] [Created] (KAFKA-6791) Add a CoordinatorNodeProvider in KafkaAdminClient

Guozhang Wang created KAFKA-6791: Summary: Add a CoordinatorNodeProvider in KafkaAdminClient Key: KAFKA-6791 URL: https://issues.apache.org/jira/browse/KAFKA-6791 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6789) Add retry logic in AdminClient requests

Guozhang Wang created KAFKA-6789: Summary: Add retry logic in AdminClient requests Key: KAFKA-6789 URL: https://issues.apache.org/jira/browse/KAFKA-6789 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client

Guozhang Wang created KAFKA-6788: Summary: Grouping consumer requests per consumer coordinator in admin client Key: KAFKA-6788 URL: https://issues.apache.org/jira/browse/KAFKA-6788 Project: Kafka

[jira] [Created] (KAFKA-6786) Remove additional configs in StreamsStandbyTask

Guozhang Wang created KAFKA-6786: Summary: Remove additional configs in StreamsStandbyTask Key: KAFKA-6786 URL: https://issues.apache.org/jira/browse/KAFKA-6786 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6748) Scheduler cannot be cancelled from Punctuator

[ https://issues.apache.org/jira/browse/KAFKA-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6748. -- Resolution: Fixed Fix Version/s: (was: 1.0.2) 1.2.0 > Scheduler

[jira] [Resolved] (KAFKA-6731) waitOnState waits for the wrong state instead of the target one

[ https://issues.apache.org/jira/browse/KAFKA-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6731. -- Resolution: Fixed Fix Version/s: 1.2.0 > waitOnState waits for the wrong state instead

[jira] [Resolved] (KAFKA-6732) 404 on streams/developer-guide/write-streams.html for processor topology

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

[jira] [Resolved] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6395. -- Resolution: Duplicate > KIP: Add Record Header support to Kafka Streams >

[jira] [Resolved] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6723. -- Resolution: Duplicate > Separate "max.poll.record" for restore consumer and common consumer >

[jira] [Created] (KAFKA-6721) Consolidate state store management for global stores and normal stores

Guozhang Wang created KAFKA-6721: Summary: Consolidate state store management for global stores and normal stores Key: KAFKA-6721 URL: https://issues.apache.org/jira/browse/KAFKA-6721 Project: Kafka

[jira] [Resolved] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6692. -- Resolution: Not A Problem > Kafka Streams internal topics should be prefixed with an underscore

[jira] [Reopened] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-6592: -- > NullPointerException thrown when executing ConsoleCosumer with deserializer > set to

[jira] [Resolved] (KAFKA-6634) Delay initiating the txn on producers until initializeTopology with EOS turned on

[ https://issues.apache.org/jira/browse/KAFKA-6634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6634. -- Resolution: Fixed Fix Version/s: 1.1.0 > Delay initiating the txn on producers until

[jira] [Created] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

Guozhang Wang created KAFKA-6641: Summary: Consider auto repartitioning for Stream.transform() API Key: KAFKA-6641 URL: https://issues.apache.org/jira/browse/KAFKA-6641 Project: Kafka Issue

[jira] [Created] (KAFKA-6634) Delay initiating the txn on producers until initializeTopology with EOS turned on

Guozhang Wang created KAFKA-6634: Summary: Delay initiating the txn on producers until initializeTopology with EOS turned on Key: KAFKA-6634 URL: https://issues.apache.org/jira/browse/KAFKA-6634

[jira] [Created] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

Guozhang Wang created KAFKA-6629: Summary: SegmentedCacheFunctionTest does not cover session window serdes Key: KAFKA-6629 URL: https://issues.apache.org/jira/browse/KAFKA-6629 Project: Kafka

[jira] [Created] (KAFKA-6628) RocksDBSegmentedBytesStoreTest does not cover time window serdes

Guozhang Wang created KAFKA-6628: Summary: RocksDBSegmentedBytesStoreTest does not cover time window serdes Key: KAFKA-6628 URL: https://issues.apache.org/jira/browse/KAFKA-6628 Project: Kafka

[jira] [Created] (KAFKA-6611) Re-write simple benchmark in system tests with JMXTool

Guozhang Wang created KAFKA-6611: Summary: Re-write simple benchmark in system tests with JMXTool Key: KAFKA-6611 URL: https://issues.apache.org/jira/browse/KAFKA-6611 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6560. -- Resolution: Fixed Fix Version/s: 1.2.0 > Use single-point queries than range queries for

[jira] [Resolved] (KAFKA-4920) Stamped should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4920. -- Resolution: Won't Fix > Stamped should implement equals > --- > >

[jira] [Resolved] (KAFKA-4921) AssignedPartition should implement equals

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6328. -- Resolution: Fixed Fix Version/s: 1.1.0 > Exclude node groups belonging to global stores

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

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

[jira] [Created] (KAFKA-6589) Extract Heartbeat thread from Abstract Coordinator for testability purposes

Guozhang Wang created KAFKA-6589: Summary: Extract Heartbeat thread from Abstract Coordinator for testability purposes Key: KAFKA-6589 URL: https://issues.apache.org/jira/browse/KAFKA-6589 Project:

[jira] [Created] (KAFKA-6585) Sonsolidate duplicated logic on reset tools

Guozhang Wang created KAFKA-6585: Summary: Sonsolidate duplicated logic on reset tools Key: KAFKA-6585 URL: https://issues.apache.org/jira/browse/KAFKA-6585 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6579) Consolidate window store and session store unit tests into a single class

Guozhang Wang created KAFKA-6579: Summary: Consolidate window store and session store unit tests into a single class Key: KAFKA-6579 URL: https://issues.apache.org/jira/browse/KAFKA-6579 Project:

[jira] [Resolved] (KAFKA-4651) Improve test coverage of Stores

[ https://issues.apache.org/jira/browse/KAFKA-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4651. -- Resolution: Fixed Assignee: Bill Bejeck Fix Version/s: 1.2.0 > Improve test

[jira] [Reopened] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4969: -- > State-store workload-aware StreamsPartitionAssignor >

[jira] [Created] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate

Guozhang Wang created KAFKA-6567: Summary: KStreamWindowReduce can be replaced by KStreamWindowAggregate Key: KAFKA-6567 URL: https://issues.apache.org/jira/browse/KAFKA-6567 Project: Kafka

[jira] [Created] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

Guozhang Wang created KAFKA-6560: Summary: Use single-point queries than range queries for windowed aggregation operators Key: KAFKA-6560 URL: https://issues.apache.org/jira/browse/KAFKA-6560

[jira] [Resolved] (KAFKA-6552) “entity_type” not exactly in description of kafka-configs.sh

[ https://issues.apache.org/jira/browse/KAFKA-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6552. -- Resolution: Fixed Assignee: Xin Fix Version/s: 1.2.0 > “entity_type” not

[jira] [Resolved] (KAFKA-4641) Improve test coverage of StreamsThread

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

[jira] [Created] (KAFKA-6535) Set default retention ms for Streams repartition topics to infinity

Guozhang Wang created KAFKA-6535: Summary: Set default retention ms for Streams repartition topics to infinity Key: KAFKA-6535 URL: https://issues.apache.org/jira/browse/KAFKA-6535 Project: Kafka

[jira] [Created] (KAFKA-6534) Consumer.poll may not trigger rebalance in time when there is a task migration

Guozhang Wang created KAFKA-6534: Summary: Consumer.poll may not trigger rebalance in time when there is a task migration Key: KAFKA-6534 URL: https://issues.apache.org/jira/browse/KAFKA-6534

[jira] [Resolved] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6499. -- Resolution: Fixed Fix Version/s: 1.2.0 1.1.0 > Avoid creating dummy

[jira] [Created] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

Guozhang Wang created KAFKA-6499: Summary: Avoid creating dummy checkpoint files with no state stores Key: KAFKA-6499 URL: https://issues.apache.org/jira/browse/KAFKA-6499 Project: Kafka

[jira] [Resolved] (KAFKA-6451) Simplify KStreamReduce

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

[jira] [Created] (KAFKA-6498) Add RocksDB statistics via Streams metrics

Guozhang Wang created KAFKA-6498: Summary: Add RocksDB statistics via Streams metrics Key: KAFKA-6498 URL: https://issues.apache.org/jira/browse/KAFKA-6498 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5509) add gradle option for building tarball with test jars

[ https://issues.apache.org/jira/browse/KAFKA-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5509. -- Resolution: Won't Fix We are going to release the testing artifact gradually in the future

[jira] [Resolved] (KAFKA-2334) Prevent HW from going back during leader failover

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

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