Guozhang Wang created KAFKA-14847:
-
Summary: Separate the callers of commitAllTasks v.s. commitTasks
for EOS(-v2) and ALOS
Key: KAFKA-14847
URL: https://issues.apache.org/jira/browse/KAFKA-14847
Proje
[
https://issues.apache.org/jira/browse/KAFKA-12639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12639.
---
Fix Version/s: 3.5.0
Resolution: Fixed
> AbstractCoordinator ignores backoff timeout
[
https://issues.apache.org/jira/browse/KAFKA-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-14253.
---
Fix Version/s: 3.5.0
Resolution: Fixed
> StreamsPartitionAssignor should print the me
Guozhang Wang created KAFKA-14641:
-
Summary: Cleanup CommitNeeded after EOS-V1 is removed
Key: KAFKA-14641
URL: https://issues.apache.org/jira/browse/KAFKA-14641
Project: Kafka
Issue Type: Im
Guozhang Wang created KAFKA-14239:
-
Summary: Merge StateRestorationIntegrationTest into
RestoreIntegrationTest
Key: KAFKA-14239
URL: https://issues.apache.org/jira/browse/KAFKA-14239
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-14130.
---
Fix Version/s: 3.4.0
Assignee: Guozhang Wang (was: Eslam)
Resolution: Fixed
Guozhang Wang created KAFKA-14138:
-
Summary: The Exception Throwing Behavior of Transactional Producer
is Inconsistent
Key: KAFKA-14138
URL: https://issues.apache.org/jira/browse/KAFKA-14138
Project:
[
https://issues.apache.org/jira/browse/KAFKA-13877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13877.
---
Resolution: Fixed
> Flaky
> RackAwarenessIntegrationTest.shouldDistributeStandbyReplicasOve
Guozhang Wang created KAFKA-14130:
-
Summary: Reduce RackAwarenessIntegrationTest to a unit test
Key: KAFKA-14130
URL: https://issues.apache.org/jira/browse/KAFKA-14130
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-13846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13846.
---
Fix Version/s: 3.3.0
Resolution: Fixed
> Add an overloaded metricOrElseCreate functio
[
https://issues.apache.org/jira/browse/KAFKA-13880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13880.
---
Fix Version/s: 3.3.0
Assignee: Guozhang Wang
Resolution: Fixed
> DefaultStre
Guozhang Wang created KAFKA-13934:
-
Summary: Consider consolidating TimeWindow / SessionWindow /
SlidingWindow
Key: KAFKA-13934
URL: https://issues.apache.org/jira/browse/KAFKA-13934
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13745.
---
Resolution: Fixed
> Flaky
> kafka.network.SocketServerTest.testNoOpActionResponseWithThrott
[
https://issues.apache.org/jira/browse/KAFKA-13800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13800.
---
Resolution: Fixed
> Remove force cast of TimeWindowKStreamImpl in tests of
> https://github
[
https://issues.apache.org/jira/browse/KAFKA-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13746.
---
Resolution: Fixed
> Flaky
> kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsr
Guozhang Wang created KAFKA-13877:
-
Summary: Flaky
RackAwarenessIntegrationTest.shouldDistributeStandbyReplicasOverMultipleClientTags
Key: KAFKA-13877
URL: https://issues.apache.org/jira/browse/KAFKA-13877
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13647.
---
Resolution: Incomplete
I resolved the ticket for now as incomplete, since the streams code c
Guozhang Wang created KAFKA-13846:
-
Summary: Add an overloaded metricOrElseCreate function in Metrics
Key: KAFKA-13846
URL: https://issues.apache.org/jira/browse/KAFKA-13846
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13799.
---
Fix Version/s: 3.3.0
Assignee: RivenSun
Resolution: Fixed
> Improve document
[
https://issues.apache.org/jira/browse/KAFKA-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13692.
---
Fix Version/s: 3.3.0
(was: 3.2.0)
Resolution: Fixed
> stream t
Guozhang Wang created KAFKA-13766:
-
Summary: Use `max.poll.interval.ms` as the timeout during
complete-rebalance phase
Key: KAFKA-13766
URL: https://issues.apache.org/jira/browse/KAFKA-13766
Project:
Guozhang Wang created KAFKA-13765:
-
Summary: Describe-consumer admin should not return unstable
membership information
Key: KAFKA-13765
URL: https://issues.apache.org/jira/browse/KAFKA-13765
Project:
[
https://issues.apache.org/jira/browse/KAFKA-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13728.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> PushHttpMetricsReporter no longer pushes met
Guozhang Wang created KAFKA-13746:
-
Summary: Flaky
kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsrPartitionsMixed
Key: KAFKA-13746
URL: https://issues.apache.org/jira/browse/KAFKA-13746
Guozhang Wang created KAFKA-13745:
-
Summary: Flaky
kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone
Key: KAFKA-13745
URL: https://issues.apache.org/jira/browse/KA
Guozhang Wang created KAFKA-13737:
-
Summary: Flaky
kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection
Key: KAFKA-13737
URL: https://issues.apache.org/jira/browse/KAFKA-13737
Project: K
[
https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-13736:
---
> Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives
>
[
https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13736.
---
Resolution: Duplicate
> Flaky kafka.network.SocketServerTest.closingChannelWithBufferedRecei
Guozhang Wang created KAFKA-13736:
-
Summary: Flaky
kafka.network.SocketServerTest.closingChannelWithBufferedReceives
Key: KAFKA-13736
URL: https://issues.apache.org/jira/browse/KAFKA-13736
Project: Ka
Guozhang Wang created KAFKA-13735:
-
Summary: Flaky
kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives
Key: KAFKA-13735
URL: https://issues.apache.org/jira/browse/KAFKA-13735
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-13421:
---
Re-opening this ticket since the test is still failing.
> Fix
> ConsumerBounceTest#testRolling
Guozhang Wang created KAFKA-13722:
-
Summary: Update internal interfaces that use ProcessorContext to
use StateStoreContext instead
Key: KAFKA-13722
URL: https://issues.apache.org/jira/browse/KAFKA-13722
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12256.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> auto commit causes delays due to retriable U
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13310.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> KafkaConsumer cannot jump out of the poll me
[
https://issues.apache.org/jira/browse/KAFKA-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13563.
---
Fix Version/s: 3.2.0
3.1.1
Resolution: Fixed
> FindCoordinatorFutu
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13346.
---
Resolution: Not A Problem
> Kafka Streams fails due to RocksDB Locks Not Available Exception
Guozhang Wang created KAFKA-13561:
-
Summary: Consider deprecating `StreamsBuilder#build(props)`
function
Key: KAFKA-13561
URL: https://issues.apache.org/jira/browse/KAFKA-13561
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13319.
---
Fix Version/s: 3.1.0
Assignee: Guozhang Wang (was: Ryan)
Resolution: Fixed
Guozhang Wang created KAFKA-13371:
-
Summary: Consider consolidating Joined / StreamJoined / TableJoined
Key: KAFKA-13371
URL: https://issues.apache.org/jira/browse/KAFKA-13371
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13268.
---
Resolution: Duplicate
> Add more integration tests for Table Table FK joins with repartition
Guozhang Wang created KAFKA-13356:
-
Summary: Use "delete" retention policy only for stream-stream join
windowed stores
Key: KAFKA-13356
URL: https://issues.apache.org/jira/browse/KAFKA-13356
Project:
Guozhang Wang created KAFKA-13349:
-
Summary: Allow Iterator.remove on KeyValueIterator
Key: KAFKA-13349
URL: https://issues.apache.org/jira/browse/KAFKA-13349
Project: Kafka
Issue Type: Impro
[
https://issues.apache.org/jira/browse/KAFKA-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13301.
---
Fix Version/s: 3.1.0
Resolution: Fixed
> The relationship between request.timeout. ms
[
https://issues.apache.org/jira/browse/KAFKA-13216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13216.
---
Resolution: Fixed
> Streams left/outer joins cause new internal changelog topic to grow unbo
[
https://issues.apache.org/jira/browse/KAFKA-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13249.
---
Fix Version/s: 3.1.0
Resolution: Fixed
> Checkpoints do not contain latest offsets on
Guozhang Wang created KAFKA-13286:
-
Summary: Revisit Streams State Store and Serde Implementation
Key: KAFKA-13286
URL: https://issues.apache.org/jira/browse/KAFKA-13286
Project: Kafka
Issue
Guozhang Wang created KAFKA-13268:
-
Summary: Add more integration tests for Table Table FK joins with
repartitioning
Key: KAFKA-13268
URL: https://issues.apache.org/jira/browse/KAFKA-13268
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13257.
---
Resolution: Not A Problem
> KafkaStreams Support For Latest RocksDB Version
> --
[
https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13175.
---
Fix Version/s: 3.1.0
Resolution: Fixed
> The topic is marked for deletion, create top
Guozhang Wang created KAFKA-13243:
-
Summary: Differentiate metric latency measured in millis and nanos
Key: KAFKA-13243
URL: https://issues.apache.org/jira/browse/KAFKA-13243
Project: Kafka
I
Guozhang Wang created KAFKA-13239:
-
Summary: Use RocksDB.ingestExternalFile for restoration
Key: KAFKA-13239
URL: https://issues.apache.org/jira/browse/KAFKA-13239
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-13170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13170.
---
Fix Version/s: 3.1.0
Resolution: Fixed
> Flaky Test InternalTopicManagerTest.shouldRe
Guozhang Wang created KAFKA-13172:
-
Summary: Document in Streams 3.0 that due to rocksDB footer
version in-filght downgrade is not supported
Key: KAFKA-13172
URL: https://issues.apache.org/jira/browse/KAFKA-13172
[
https://issues.apache.org/jira/browse/KAFKA-8683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8683.
--
Resolution: Cannot Reproduce
Have not seen this flakiness recently and also cannot reproduce lo
Guozhang Wang created KAFKA-13152:
-
Summary: Replace "buffered.records.per.partition" with
"input.buffer.max.bytes"
Key: KAFKA-13152
URL: https://issues.apache.org/jira/browse/KAFKA-13152
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-9858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9858.
--
Fix Version/s: 3.0.0
Resolution: Fixed
> CVE-2016-3189 Use-after-free vulnerability in
[
https://issues.apache.org/jira/browse/KAFKA-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13008.
---
Assignee: Guozhang Wang
Resolution: Fixed
> Stream will stop processing data for a lon
Guozhang Wang created KAFKA-12957:
-
Summary: Refactor Streams Logical Plan Generation
Key: KAFKA-12957
URL: https://issues.apache.org/jira/browse/KAFKA-12957
Project: Kafka
Issue Type: Improv
[
https://issues.apache.org/jira/browse/KAFKA-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10585.
---
Fix Version/s: 3.0.0
Resolution: Fixed
> Kafka Streams should clean up the state stor
Guozhang Wang created KAFKA-12920:
-
Summary: Consumer's cooperative sticky assignor need to clear
generation / assignment data upon `onPartitionsLost`
Key: KAFKA-12920
URL: https://issues.apache.org/jira/browse/KA
[
https://issues.apache.org/jira/browse/KAFKA-12918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12918.
---
> Watch-Free Animated 'America: The Motion Picture' Trailer 2021 Full Hd
> Download
>
[
https://issues.apache.org/jira/browse/KAFKA-10614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10614.
---
Fix Version/s: 3.0.0
Resolution: Fixed
> Group coordinator onElection/onResignation s
Guozhang Wang created KAFKA-12887:
-
Summary: Do not trigger user-customized ExceptionalHandler for RTE
Key: KAFKA-12887
URL: https://issues.apache.org/jira/browse/KAFKA-12887
Project: Kafka
I
Guozhang Wang created KAFKA-12812:
-
Summary: Consider refactoring state store registration path
Key: KAFKA-12812
URL: https://issues.apache.org/jira/browse/KAFKA-12812
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12683.
---
Fix Version/s: 3.0.0
Assignee: Guozhang Wang
Resolution: Fixed
> Remove depr
Guozhang Wang created KAFKA-12693:
-
Summary: Consecutive rebalances with zombie instances may cause
corrupted changelogs
Key: KAFKA-12693
URL: https://issues.apache.org/jira/browse/KAFKA-12693
Project
Guozhang Wang created KAFKA-12683:
-
Summary: Remove deprecated "UsePreviousTimeOnInvalidTimeStamp"
Key: KAFKA-12683
URL: https://issues.apache.org/jira/browse/KAFKA-12683
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12633.
---
Fix Version/s: 3.0.0
Resolution: Fixed
> Remove deprecated "TopologyTestDriver#pipeIn
Guozhang Wang created KAFKA-12669:
-
Summary: Add deleteRange to WindowStore / KeyValueStore interfaces
Key: KAFKA-12669
URL: https://issues.apache.org/jira/browse/KAFKA-12669
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-12643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12643.
---
Resolution: Duplicate
Thanks for confirming!
> Kafka Streams 2.7 with Kafka Broker 2.6.x re
Guozhang Wang created KAFKA-12633:
-
Summary: Remove deprecated "TopologyTestDriver#pipeInput /
readOutput"
Key: KAFKA-12633
URL: https://issues.apache.org/jira/browse/KAFKA-12633
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12630.
---
Fix Version/s: 3.0.0
Resolution: Fixed
> Remove deprecated KafkaClientSupplier#getAdm
[
https://issues.apache.org/jira/browse/KAFKA-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12568.
---
Fix Version/s: 3.0.0
Assignee: Guozhang Wang
Resolution: Fixed
> Remove depr
Guozhang Wang created KAFKA-12630:
-
Summary: Remove deprecated KafkaClientSupplier#getAdminClient
Key: KAFKA-12630
URL: https://issues.apache.org/jira/browse/KAFKA-12630
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7785.
--
Resolution: Fixed
> Remove PartitionGrouper interface and it's config and move
> DefaultPartit
[
https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9765.
--
Resolution: Duplicate
> Could not add partitions to transaction due to errors
> ---
[
https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12428.
---
Resolution: Duplicate
> Add a last-heartbeat-seconds-ago metric to Kafka Consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-7106.
--
Resolution: Fixed
> Remove segment/segmentInterval from Window definition
> ---
[
https://issues.apache.org/jira/browse/KAFKA-12562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12562.
---
Resolution: Fixed
> Remove deprecated-overloaded "KafkaStreams#metadataForKey" and
> "Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12524.
---
Resolution: Fixed
> Remove deprecated WindowBytesStoreSupplier#segments
> --
Guozhang Wang created KAFKA-12568:
-
Summary: Remove deprecated "KStream#groupBy/join", "Joined#named"
overloads
Key: KAFKA-12568
URL: https://issues.apache.org/jira/browse/KAFKA-12568
Project: Kafka
Guozhang Wang created KAFKA-12562:
-
Summary: Remove deprecated-overloaded
"KafkaStreams#metadataForKey" and "KafkaStreams#store"
Key: KAFKA-12562
URL: https://issues.apache.org/jira/browse/KAFKA-12562
[
https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12527.
---
Resolution: Duplicate
> Remove deprecated "PartitionGrouper" interface
> ---
[
https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12526.
---
Resolution: Duplicate
> Remove deprecated long ms overloads
> --
Guozhang Wang created KAFKA-12549:
-
Summary: Allow state stores to opt-in transactional support
Key: KAFKA-12549
URL: https://issues.apache.org/jira/browse/KAFKA-12549
Project: Kafka
Issue Ty
Guozhang Wang created KAFKA-12527:
-
Summary: Remove deprecated "PartitionAssignor" interface
Key: KAFKA-12527
URL: https://issues.apache.org/jira/browse/KAFKA-12527
Project: Kafka
Issue Type:
Guozhang Wang created KAFKA-12526:
-
Summary: Remove deprecated long ms overloads
Key: KAFKA-12526
URL: https://issues.apache.org/jira/browse/KAFKA-12526
Project: Kafka
Issue Type: Sub-task
Guozhang Wang created KAFKA-12524:
-
Summary: Remove deprecated WindowBytesStoreSupplier#segments
Key: KAFKA-12524
URL: https://issues.apache.org/jira/browse/KAFKA-12524
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12514.
---
Fix Version/s: 3.0.0
Resolution: Fixed
> NPE in SubscriptionState
> -
Guozhang Wang created KAFKA-12472:
-
Summary: Add a Consumer / Streams metric to indicate the current
rebalance status
Key: KAFKA-12472
URL: https://issues.apache.org/jira/browse/KAFKA-12472
Project: K
Guozhang Wang created KAFKA-12428:
-
Summary: Add a last-heartbeat-seconds-ago metric to Kafka Consumer
Key: KAFKA-12428
URL: https://issues.apache.org/jira/browse/KAFKA-12428
Project: Kafka
I
Guozhang Wang created KAFKA-12419:
-
Summary: Remove Deprecated APIs of Kafka Streams in 3.0
Key: KAFKA-12419
URL: https://issues.apache.org/jira/browse/KAFKA-12419
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12323.
---
Resolution: Fixed
> Record timestamps not populated in event
> -
Guozhang Wang created KAFKA-12370:
-
Summary: Refactor KafkaStreams exposed metadata hierarchy
Key: KAFKA-12370
URL: https://issues.apache.org/jira/browse/KAFKA-12370
Project: Kafka
Issue Type
Guozhang Wang created KAFKA-12352:
-
Summary: Improve debuggability with continuous consumer rebalances
Key: KAFKA-12352
URL: https://issues.apache.org/jira/browse/KAFKA-12352
Project: Kafka
I
Guozhang Wang created KAFKA-12242:
-
Summary: Decouple state store materialization enforcement from
name/serde provider
Key: KAFKA-12242
URL: https://issues.apache.org/jira/browse/KAFKA-12242
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12219.
---
Fix Version/s: 2.8.0
Resolution: Fixed
> Potential race condition in InMemoryKeyValue
Guozhang Wang created KAFKA-10830:
-
Summary: Kafka Producer API should throw unwrapped exceptions
Key: KAFKA-10830
URL: https://issues.apache.org/jira/browse/KAFKA-10830
Project: Kafka
Issue
Guozhang Wang created KAFKA-10829:
-
Summary: Kafka Streams handle produce exception improvement
Key: KAFKA-10829
URL: https://issues.apache.org/jira/browse/KAFKA-10829
Project: Kafka
Issue Ty
Guozhang Wang created KAFKA-10725:
-
Summary: Merge StoreQueryIntegrationTest and
QueryableStateIntegrationTest
Key: KAFKA-10725
URL: https://issues.apache.org/jira/browse/KAFKA-10725
Project: Kafka
1 - 100 of 4131 matches
Mail list logo