Guozhang Wang created KAFKA-7502:
Summary: Cleanup KTable materialization logic in a single place
Key: KAFKA-7502
URL: https://issues.apache.org/jira/browse/KAFKA-7502
Project: Kafka
Issue Ty
Guozhang Wang created KAFKA-7658:
Summary: Add KStream#toTable to the Streams DSL
Key: KAFKA-7658
URL: https://issues.apache.org/jira/browse/KAFKA-7658
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-7536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7536.
--
Resolution: Fixed
Assignee: Guozhang Wang
Fix Version/s: 2.0.2
[
https://issues.apache.org/jira/browse/KAFKA-7528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7528.
--
Resolution: Fixed
> Standardize on Min/Avg/Max Kafka metrics' default value
> -
[
https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7660.
--
Resolution: Fixed
Assignee: John Roesler
Fix Version/s: 2.2.0
> Stream Metrics
[
https://issues.apache.org/jira/browse/KAFKA-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4219.
--
Resolution: Fixed
Fix Version/s: 2.0.0
> Permit setting of event time in stream processo
[
https://issues.apache.org/jira/browse/KAFKA-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7673.
--
Resolution: Fixed
Assignee: Guozhang Wang
[~yanicks] we've merged https://github.com/apac
[
https://issues.apache.org/jira/browse/KAFKA-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7709.
--
Resolution: Fixed
Fix Version/s: 2.1.1
2.2.0
Thanks [~markcho] for yo
[
https://issues.apache.org/jira/browse/KAFKA-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6036.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Enable logical materialization to physical mate
Guozhang Wang created KAFKA-7718:
Summary: Allow customized header inheritance for stateful
operators in DSL
Key: KAFKA-7718
URL: https://issues.apache.org/jira/browse/KAFKA-7718
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7610.
--
Resolution: Fixed
Assignee: Jason Gustafson (was: Boyang Chen)
Fix Version/s: 2
[
https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-5386.
--
Resolution: Fixed
Fix Version/s: 1.0.0
> [Kafka Streams] - custom name for state-store c
Guozhang Wang created KAFKA-7734:
Summary: Metrics tags should use LinkedHashMap to guarantee
ordering
Key: KAFKA-7734
URL: https://issues.apache.org/jira/browse/KAFKA-7734
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-7734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7734.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Metrics tags should use LinkedHashMap to guaran
[
https://issues.apache.org/jira/browse/KAFKA-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6928.
--
Resolution: Fixed
Fix Version/s: 2.1.1
2.2.0
> StreamsPartitionAssign
[
https://issues.apache.org/jira/browse/KAFKA-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7181.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Kafka Streams State stuck in rebalancing after
[
https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7657.
--
Resolution: Fixed
Assignee: Guozhang Wang
Fix Version/s: 2.2.0
> Invalid report
[
https://issues.apache.org/jira/browse/KAFKA-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7768.
--
Resolution: Fixed
Fix Version/s: 2.1.1
2.2.0
> Java doc link 404
> -
[
https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4468.
--
Resolution: Fixed
Assignee: Richard Yu
> Correctly calculate the window end timestamp aft
[
https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4218.
--
Resolution: Fixed
Fix Version/s: (was: 1.1.0)
2.1.0
This has been
Guozhang Wang created KAFKA-7798:
Summary: Expose embedded client context from KafkaStreams
threadMetadata
Key: KAFKA-7798
URL: https://issues.apache.org/jira/browse/KAFKA-7798
Project: Kafka
Guozhang Wang created KAFKA-7808:
Summary: AdminClient#describeTopic should not throw InvalidTopic
if topic name is not found
Key: KAFKA-7808
URL: https://issues.apache.org/jira/browse/KAFKA-7808
Proj
[
https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7741.
--
Resolution: Fixed
Fix Version/s: 2.0.2
2.1.1
2.2.0
[
https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7808.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> AdminClient#describeTopics should not throw Inv
[
https://issues.apache.org/jira/browse/KAFKA-6803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6803.
--
Resolution: Invalid
> Caching is turned off for stream-stream Join
> --
[
https://issues.apache.org/jira/browse/KAFKA-7024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7024.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Rocksdb state directory should be created befor
[
https://issues.apache.org/jira/browse/KAFKA-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6964.
--
Resolution: Won't Fix
> Add ability to print all internal topic names
> ---
[
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://githu
[
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-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
> Remove
[
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 ti
[
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 do
[
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 globa
[
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-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 Reset
[
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
> ---
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: Improve
[
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
> --
[
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-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-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
> --
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: Im
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
[
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
> -
[
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 inte
[
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 seri
[
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
> org.apache.kafka.streams.processor.internals.StreamThread
[
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-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.
> Removed
[
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
inh
[
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-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 res
[
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-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.
> transien
[
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
p
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-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
> --
[
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-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 KStream/KTable
[
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
> StreamThrea
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-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7021.
--
Resolution: Fixed
> Source KTable checkpoint is not correct
> -
[
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 n
[
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 exception
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 Type:
[
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-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-7097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7097.
--
Resolution: Fixed
Assignee: Ted Yu
Reviewer: Guozhang Wang
Fix Version/
[
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 Thre
[
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 `c
[
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 proce
[
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-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://gith
[
https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6437.
--
Resolution: Fixed
Assignee: Ted Yu (was: Mariam John)
Fix Version/s: 2.1.0
> S
[
https://issues.apache.org/jira/browse/KAFKA-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6587.
--
Resolution: Fixed
Assignee: Ted Yu
Fix Version/s: 2.1.0
> Kafka Streams hangs w
[
https://issues.apache.org/jira/browse/KAFKA-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7195.
--
Resolution: Fixed
Fix Version/s: 2.0.0
> StreamStreamJoinIntegrationTest fails in 2.0 Je
[
https://issues.apache.org/jira/browse/KAFKA-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7144.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> Kafka Streams doesn't properly balance partitio
Guozhang Wang created KAFKA-7203:
Summary: Improve Streams StickyTaskAssingor
Key: KAFKA-7203
URL: https://issues.apache.org/jira/browse/KAFKA-7203
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7192.
--
Resolution: Fixed
> State-store can desynchronise with changelog
>
[
https://issues.apache.org/jira/browse/KAFKA-6999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6999.
--
Resolution: Fixed
Assignee: Lee Dongjin
Fix Version/s: 2.1.0
> Document read-wr
[
https://issues.apache.org/jira/browse/KAFKA-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7161.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> KTable Reduce should check for invalid conditio
[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7125.
--
Resolution: Won't Fix
> Calling StreamsBuilderbuilder.build().describe() causes
> java.util.No
[
https://issues.apache.org/jira/browse/KAFKA-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7049.
--
Resolution: Cannot Reproduce
> InternalTopicIntegrationTest sometimes fails
> -
[
https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4479.
--
Resolution: Won't Fix
> Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordin
Guozhang Wang created KAFKA-7243:
Summary: Add unit integration tests to validate metrics in Kafka
Streams
Key: KAFKA-7243
URL: https://issues.apache.org/jira/browse/KAFKA-7243
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6383.
--
Resolution: Fixed
Issue resolved by pull request 4382
[https://github.com/apache/kafka/pull/4382
Guozhang Wang created KAFKA-6443:
Summary: KTable involved in multiple joins could result in
duplicate results
Key: KAFKA-6443
URL: https://issues.apache.org/jira/browse/KAFKA-6443
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-4186:
--
Assignee: Matthias J. Sax (was: Damian Guy)
> Transient failure in KStreamAggregationIntegrat
[
https://issues.apache.org/jira/browse/KAFKA-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6398.
--
Resolution: Fixed
Fix Version/s: 1.0.1
1.1.0
> Non-aggregation KTable
[
https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-1482.
--
Resolution: Cannot Reproduce
Fix Version/s: (was: 1.1.0)
> Transient test failures fo
[
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.1
[
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 relea
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: Improvem
[
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-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
Issu
[
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 ch
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
Project:
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
[
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 co
[
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 exactly
1 - 100 of 4131 matches
Mail list logo
