Guozhang Wang created KAFKA-8420:
Summary: Graceful handling when consumer switches from subscribe
to manual assign
Key: KAFKA-8420
URL: https://issues.apache.org/jira/browse/KAFKA-8420
Project:
[
https://issues.apache.org/jira/browse/KAFKA-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8389.
--
Resolution: Won't Fix
> Duplicated MockProcessorSupplier / MockProcessor in
[
https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6474.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> Rewrite test to use new public
Guozhang Wang created KAFKA-8389:
Summary: Duplicated MockProcessorSupplier / MockProcessor in
TopologyTestDriverTest
Key: KAFKA-8389
URL: https://issues.apache.org/jira/browse/KAFKA-8389
Project:
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7190.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> Under low traffic conditions purging
[
https://issues.apache.org/jira/browse/KAFKA-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8313.
--
Resolution: Fixed
Assignee: Guozhang Wang
Fix Version/s: 2.3.0
> KafkaStreams
[
https://issues.apache.org/jira/browse/KAFKA-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8285.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> Handle thread-id random switch on JVM for
[
https://issues.apache.org/jira/browse/KAFKA-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8029.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> Add in-memory bytes-only session store
[
https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8254.
--
Resolution: Fixed
Fix Version/s: (was: 2.1.2)
Resolved for trunk / 2.2 now, will
[
https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8291.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> System test consumer_test.py failed on trunk
>
[
https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8204.
--
Resolution: Fixed
Fix Version/s: (was: 2.1.2)
(was: 2.0.2)
[
https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7652.
--
Resolution: Fixed
Fix Version/s: 2.3.0
It should be fixed by the latest PR (details
[
https://issues.apache.org/jira/browse/KAFKA-5784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-5784.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> Add a sensor for dropped records in window
[
https://issues.apache.org/jira/browse/KAFKA-8157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8157.
--
Resolution: Fixed
Assignee: Guozhang Wang
Fix Version/s: 2.2.1
Guozhang Wang created KAFKA-8197:
Summary: Flaky Test kafka.server.DynamicBrokerConfigTest >
testPasswordConfigEncoderSecretChange
Key: KAFKA-8197
URL: https://issues.apache.org/jira/browse/KAFKA-8197
Guozhang Wang created KAFKA-8179:
Summary: Incremental Rebalance Protocol for Kafka Consumer
Key: KAFKA-8179
URL: https://issues.apache.org/jira/browse/KAFKA-8179
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4600.
--
Resolution: Fixed
Fix Version/s: 0.11.0.0
> Consumer proceeds on when
[
https://issues.apache.org/jira/browse/KAFKA-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4799.
--
Resolution: Fixed
Fix Version/s: 0.11.0.1
> session timeout during event processing
[
https://issues.apache.org/jira/browse/KAFKA-6631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6631.
--
Resolution: Fixed
Just a side note that we are working on KAFKA-7149 to reduce the assignment
[
https://issues.apache.org/jira/browse/KAFKA-7142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7142.
--
Resolution: Fixed
Fix Version/s: 2.1.0
Resolving the ticket since the PR is merged as
[
https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6681.
--
Resolution: Fixed
Fix Version/s: 0.11.0.0
Resolving as part of
[
https://issues.apache.org/jira/browse/KAFKA-8166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8166.
--
Resolution: Fixed
Assignee: Guozhang Wang
Fix Version/s: 2.2.0
> Kafka 2.2
[
https://issues.apache.org/jira/browse/KAFKA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-1149.
--
Resolution: Fixed
> Please delete old releases from mirroring system
>
Guozhang Wang created KAFKA-8135:
Summary: Kafka Producer deadlocked on flush call with intermittent
broker unavailability
Key: KAFKA-8135
URL: https://issues.apache.org/jira/browse/KAFKA-8135
Guozhang Wang created KAFKA-8126:
Summary: Flaky Test
org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask
Key: KAFKA-8126
URL: https://issues.apache.org/jira/browse/KAFKA-8126
Project:
Guozhang Wang created KAFKA-8108:
Summary: Flaky Test
kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer
Key: KAFKA-8108
URL: https://issues.apache.org/jira/browse/KAFKA-8108
Project: Kafka
Guozhang Wang created KAFKA-8107:
Summary: Flaky Test
kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete
Key: KAFKA-8107
URL: https://issues.apache.org/jira/browse/KAFKA-8107
Project: Kafka
Guozhang Wang created KAFKA-8029:
Summary: Add in-memory bytes-only session store implementation
Key: KAFKA-8029
URL: https://issues.apache.org/jira/browse/KAFKA-8029
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-7652:
--
> Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0
>
[
https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-5122.
--
Resolution: Not A Problem
> Kafka Streams unexpected off-heap memory growth
>
[
https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-5122:
--
> Kafka Streams unexpected off-heap memory growth
>
[
https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-7628:
--
> KafkaStream is not closing
> --
>
> Key: KAFKA-7628
>
[
https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7628.
--
Resolution: Not A Problem
> KafkaStream is not closing
> --
>
>
Guozhang Wang created KAFKA-8017:
Summary: Narrow the scope of Streams' broker-upgrade-test
Key: KAFKA-8017
URL: https://issues.apache.org/jira/browse/KAFKA-8017
Project: Kafka
Issue Type:
Guozhang Wang created KAFKA-7985:
Summary: Cleanup AssignedTasks / AbstractTask logic
Key: KAFKA-7985
URL: https://issues.apache.org/jira/browse/KAFKA-7985
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6161.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> Add default implementation to close() and
[
https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-4730.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> Streams does not have an in-memory windowed
[
https://issues.apache.org/jira/browse/KAFKA-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7811.
--
Resolution: Fixed
Fix Version/s: 2.3.0
> Avoid unnecessary lock acquire when
[
https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7652.
--
Resolution: Fixed
Assignee: Guozhang Wang
Fix Version/s: 2.2.0
I think this
[
https://issues.apache.org/jira/browse/KAFKA-7872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7872.
--
Resolution: Duplicate
> Consider allowing transformations on GlobalKTable before
Guozhang Wang created KAFKA-7872:
Summary: Consider allowing transformations on GlobalKTable before
materialization
Key: KAFKA-7872
URL: https://issues.apache.org/jira/browse/KAFKA-7872
Project:
Guozhang Wang created KAFKA-7869:
Summary: Refactor RocksDBConfigSetter API to separate DBOptions
and CFOptions
Key: KAFKA-7869
URL: https://issues.apache.org/jira/browse/KAFKA-7869
Project: Kafka
[
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-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
[
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-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
[
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
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
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
[
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
[
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
[
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-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
[
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-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
>
[
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
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
[
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
[
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:
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-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
[
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
[
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://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
[
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-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-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
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
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
Guozhang Wang created KAFKA-7458:
Summary: Avoid enforced processing during bootstrap phase
Key: KAFKA-7458
URL: https://issues.apache.org/jira/browse/KAFKA-7458
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-6620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6620.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> Documentation about "exactly_once" doesn't
Guozhang Wang created KAFKA-7456:
Summary: Serde Inheritance in Streams DSL
Key: KAFKA-7456
URL: https://issues.apache.org/jira/browse/KAFKA-7456
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-7379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7379.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> send.buffer.bytes should be allowed to set -1
[
https://issues.apache.org/jira/browse/KAFKA-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6594.
--
Resolution: Not A Problem
> 第二次启动kafka是报错.timeindex: 另一个程序正在使用此文件，进程无法访问。
[
https://issues.apache.org/jira/browse/KAFKA-7399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7399.
--
Resolution: Fixed
> FunctionConversions in Streams-Scala should be private
>
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7316.
--
Resolution: Fixed
> Use of filter method in KTable.scala may result in StackOverflowError
>
[
https://issues.apache.org/jira/browse/KAFKA-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7386.
--
Resolution: Fixed
> Streams Scala wrapper should not cache serdes
>
[
https://issues.apache.org/jira/browse/KAFKA-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7396.
--
Resolution: Fixed
> KIP-365: Materialized, Serialized, Joined, Consumed and Produced with
>
[
https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-5882.
--
Resolution: Fixed
Fix Version/s: 1.1.1
> NullPointerException in StreamTask
>
[
https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7269.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> KStream.merge is not documented
>
Guozhang Wang created KAFKA-7326:
Summary: Let KStream.print() to flush on each printed line
Key: KAFKA-7326
URL: https://issues.apache.org/jira/browse/KAFKA-7326
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-7301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7301.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> KTable to KTable join invocation does not
[
https://issues.apache.org/jira/browse/KAFKA-7311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7311.
--
Resolution: Fixed
> Sender should reset next batch expiry time between poll loops
>
Guozhang Wang created KAFKA-7312:
Summary: Transient failure in
kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts
Key: KAFKA-7312
URL: https://issues.apache.org/jira/browse/KAFKA-7312
Guozhang Wang created KAFKA-7285:
Summary: Streams should be more fencing-sensitive during task
suspension under EOS
Key: KAFKA-7285
URL: https://issues.apache.org/jira/browse/KAFKA-7285
Project:
[
https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7158.
--
Resolution: Fixed
Assignee: John Roesler
Fix Version/s: 2.1.0
[
https://issues.apache.org/jira/browse/KAFKA-6327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6327.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> IllegalArgumentException in RocksDB when
[
https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7250.
--
Resolution: Fixed
Fix Version/s: 2.1.0
2.0.1
> Kafka-Streams-Scala
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-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
[
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-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7125.
--
Resolution: Won't Fix
> Calling StreamsBuilderbuilder.build().describe() causes
>
[
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
[
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
[
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
>
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-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
[
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
[
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
[
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
>
301 - 400 of 3849 matches
Mail list logo
