[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
>
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
[
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
[
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
[
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
>
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
[
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
>
[
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
[
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
>
[
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
>
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
[
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
[
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.
>
[
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
[
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
[
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
>
[
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
[
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.
>
[
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
> -
>
[
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
>
[
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
[
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
[
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
>
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
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:
[
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
>
[
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
[
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
>
[
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
>
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:
[
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
>
[
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
[
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
[
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
[
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
[
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
[
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
>
[
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
>
[
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
[
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
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
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
[
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
[
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
[
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
>
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
[
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
[
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
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:
[
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
[
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
>
[
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
>
[
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
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:
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:
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
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:
[
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
[
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
[
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
[
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
>
[
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
>
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
[
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
[
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
[
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
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
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
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
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
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
[
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
[
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
> ---
>
>
[
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
>
[
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
[
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
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:
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:
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:
[
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
[
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
>
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
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
[
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
[
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
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
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
[
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
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
[
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
> --
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:
[
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
[
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:
401 - 500 of 3849 matches
Mail list logo