[
https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7728.
Resolution: Won't Fix
This is no longer a critical fix to the static membership, as leader rejoin
Boyang Chen created KAFKA-12499:
---
Summary: Adjust transaction timeout according to commit interval
on Streams EOS
Key: KAFKA-12499
URL: https://issues.apache.org/jira/browse/KAFKA-12499
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-12381.
-
Resolution: Fixed
> Incompatible change in verifiable_producer.log in 2.8
>
Boyang Chen created KAFKA-12307:
---
Summary: Wrap non-fatal exception as CommitFailedException when
thrown from commitTxn
Key: KAFKA-12307
URL: https://issues.apache.org/jira/browse/KAFKA-12307
Project:
Boyang Chen created KAFKA-12304:
---
Summary: Improve topic validation in auto topic creation
Key: KAFKA-12304
URL: https://issues.apache.org/jira/browse/KAFKA-12304
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-12294:
---
Summary: Consider using the forwarding mechanism for metadata auto
topic creation
Key: KAFKA-12294
URL: https://issues.apache.org/jira/browse/KAFKA-12294
Project:
Boyang Chen created KAFKA-12260:
---
Summary: PartitionsFor should not return null value
Key: KAFKA-12260
URL: https://issues.apache.org/jira/browse/KAFKA-12260
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-12215:
---
Summary: Broker could cache its overlapping ApiVersions with
active controller
Key: KAFKA-12215
URL: https://issues.apache.org/jira/browse/KAFKA-12215
Project: Kafka
Boyang Chen created KAFKA-10868:
---
Summary: Avoid double wrapping KafkaException
Key: KAFKA-10868
URL: https://issues.apache.org/jira/browse/KAFKA-10868
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9552.
Resolution: Not A Problem
> Stream should handle OutOfSequence exception thrown from Producer
>
[
https://issues.apache.org/jira/browse/KAFKA-10813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10813.
-
Resolution: Fixed
> StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in
Boyang Chen created KAFKA-10813:
---
Summary: StreamsProducer should catch InvalidProducerEpoch and
throw TaskMigrated in all cases
Key: KAFKA-10813
URL: https://issues.apache.org/jira/browse/KAFKA-10813
Boyang Chen created KAFKA-10807:
---
Summary: AlterConfig should be validated by the target broker
Key: KAFKA-10807
URL: https://issues.apache.org/jira/browse/KAFKA-10807
Project: Kafka
Issue
Boyang Chen created KAFKA-10733:
---
Summary: Enforce exception thrown for KafkaProducer txn APIs
Key: KAFKA-10733
URL: https://issues.apache.org/jira/browse/KAFKA-10733
Project: Kafka
Issue
Boyang Chen created KAFKA-10714:
---
Summary: Save unnecessary end txn call when the transaction is
confirmed to be done
Key: KAFKA-10714
URL: https://issues.apache.org/jira/browse/KAFKA-10714
Project:
Boyang Chen created KAFKA-10699:
---
Summary: Add system test coverage for group coordinator emigration
Key: KAFKA-10699
URL: https://issues.apache.org/jira/browse/KAFKA-10699
Project: Kafka
Boyang Chen created KAFKA-10687:
---
Summary: Produce request should be bumped for new error code
PRODUCE_FENCED
Key: KAFKA-10687
URL: https://issues.apache.org/jira/browse/KAFKA-10687
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10181.
-
Resolution: Fixed
> Create Envelope RPC and redirection template for configuration change RPCs
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10343.
-
Resolution: Won't Fix
We are planning to work on a more long-term fix for this issue, see
>
Boyang Chen created KAFKA-10674:
---
Summary: Brokers should know the active controller ApiVersion
after enabling KIP-590 forwarding
Key: KAFKA-10674
URL: https://issues.apache.org/jira/browse/KAFKA-10674
Boyang Chen created KAFKA-10668:
---
Summary: Avoid deserialization on second hop for request forwarding
Key: KAFKA-10668
URL: https://issues.apache.org/jira/browse/KAFKA-10668
Project: Kafka
Boyang Chen created KAFKA-10667:
---
Summary: Add timeout for forwarding requests
Key: KAFKA-10667
URL: https://issues.apache.org/jira/browse/KAFKA-10667
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-10663:
---
Summary: Flakey test
ConsumerBounceTest#testSeekAndCommitWithBrokerFailures
Key: KAFKA-10663
URL: https://issues.apache.org/jira/browse/KAFKA-10663
Project: Kafka
Boyang Chen created KAFKA-10657:
---
Summary: Incorporate Envelope into auto-generated JSON schema
Key: KAFKA-10657
URL: https://issues.apache.org/jira/browse/KAFKA-10657
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-.
Resolution: Won't Fix
> Internal topic creation failure should be non-fatal and trigger explicit
Boyang Chen created KAFKA-10607:
---
Summary: Ensure the error counts contains the NONE
Key: KAFKA-10607
URL: https://issues.apache.org/jira/browse/KAFKA-10607
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-10594:
---
Summary: Enhance Raft exception handling
Key: KAFKA-10594
URL: https://issues.apache.org/jira/browse/KAFKA-10594
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-10508:
---
Summary: Consider moving ForwardRequestHandler to a separate class
Key: KAFKA-10508
URL: https://issues.apache.org/jira/browse/KAFKA-10508
Project: Kafka
Boyang Chen created KAFKA-10400:
---
Summary: Add a customized Kafka Streams logo
Key: KAFKA-10400
URL: https://issues.apache.org/jira/browse/KAFKA-10400
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10042.
-
Resolution: Fixed
> Make INVALID_PRODUCER_EPOCH abortable from Produce response
>
[
https://issues.apache.org/jira/browse/KAFKA-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9911.
Resolution: Fixed
> Implement new producer fenced error
> ---
>
>
Boyang Chen created KAFKA-10345:
---
Summary: Redirect AlterPartitionReassignment to the controller
Key: KAFKA-10345
URL: https://issues.apache.org/jira/browse/KAFKA-10345
Project: Kafka
Issue
Boyang Chen created KAFKA-10344:
---
Summary: Redirect Create/Renew/ExpireDelegationToken to the
controller
Key: KAFKA-10344
URL: https://issues.apache.org/jira/browse/KAFKA-10344
Project: Kafka
Boyang Chen created KAFKA-10343:
---
Summary: Redirect AlterClientQuotas to the controller
Key: KAFKA-10343
URL: https://issues.apache.org/jira/browse/KAFKA-10343
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-10342:
---
Summary: Redirect CreateAcls/DeleteAcls to the controller
Key: KAFKA-10342
URL: https://issues.apache.org/jira/browse/KAFKA-10342
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-10350:
---
Summary: Add redirect request monitoring metrics
Key: KAFKA-10350
URL: https://issues.apache.org/jira/browse/KAFKA-10350
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-10349:
---
Summary: Deprecate client side controller access
Key: KAFKA-10349
URL: https://issues.apache.org/jira/browse/KAFKA-10349
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-10348:
---
Summary: Redirect UpdateFeatures to the controller
Key: KAFKA-10348
URL: https://issues.apache.org/jira/browse/KAFKA-10348
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-10347:
---
Summary: Redirect Create/DeleteTopics to the controller
Key: KAFKA-10347
URL: https://issues.apache.org/jira/browse/KAFKA-10347
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-10346:
---
Summary: Redirect CreatePartition to the controller
Key: KAFKA-10346
URL: https://issues.apache.org/jira/browse/KAFKA-10346
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10270.
-
Resolution: Fixed
> Add a broker to controller channel manager to redirect AlterConfig
>
Boyang Chen created KAFKA-10321:
---
Summary: shouldDieOnInvalidOffsetExceptionWhileRunning would block
forever on JDK11
Key: KAFKA-10321
URL: https://issues.apache.org/jira/browse/KAFKA-10321
Project:
Boyang Chen created KAFKA-10311:
---
Summary: Flaky test KafkaAdminClientTest#testMetadataRetries
Key: KAFKA-10311
URL: https://issues.apache.org/jira/browse/KAFKA-10311
Project: Kafka
Issue
Boyang Chen created KAFKA-10307:
---
Summary: Topology cycles in
KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable
Key: KAFKA-10307
URL:
Boyang Chen created KAFKA-10284:
---
Summary: Group membership update due to static member rejoin
should be persisted
Key: KAFKA-10284
URL: https://issues.apache.org/jira/browse/KAFKA-10284
Project: Kafka
Boyang Chen created KAFKA-10270:
---
Summary: Add a broker to controller channel manager to redirect
AlterConfig
Key: KAFKA-10270
URL: https://issues.apache.org/jira/browse/KAFKA-10270
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10239.
-
Resolution: Fixed
> The groupInstanceId field in DescribeGroup response should be ignorable
>
Boyang Chen created KAFKA-10241:
---
Summary: Pursue a better way to cover ignorable RPC fields
Key: KAFKA-10241
URL: https://issues.apache.org/jira/browse/KAFKA-10241
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-10237:
---
Summary: Properly handle in-memory stores OOM
Key: KAFKA-10237
URL: https://issues.apache.org/jira/browse/KAFKA-10237
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10135.
-
Resolution: Fixed
> Extract Task#executeAndMaybeSwallow to be a general utility function into
Boyang Chen created KAFKA-10192:
---
Summary: Flaky test BlockingConnectorTest#testBlockInConnectorStop
Key: KAFKA-10192
URL: https://issues.apache.org/jira/browse/KAFKA-10192
Project: Kafka
Boyang Chen created KAFKA-10181:
---
Summary: AlterConfig/IncrementalAlterConfig should go to controller
Key: KAFKA-10181
URL: https://issues.apache.org/jira/browse/KAFKA-10181
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10087.
-
Resolution: Fixed
> Properly throw LogTruncation exception from OffsetForLeaderEpoch future
>
Boyang Chen created KAFKA-10139:
---
Summary: Add operational guide for failure recovery
Key: KAFKA-10139
URL: https://issues.apache.org/jira/browse/KAFKA-10139
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-10135:
---
Summary: Extract Task#executeAndMaybeSwallow to be a general
utility function into TaskManager
Key: KAFKA-10135
URL: https://issues.apache.org/jira/browse/KAFKA-10135
Boyang Chen created KAFKA-10130:
---
Summary: Rewrite ZkData struct with auto-generated protocol
Key: KAFKA-10130
URL: https://issues.apache.org/jira/browse/KAFKA-10130
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10097.
-
Resolution: Fixed
> Avoid passing task checkpoint file externally
>
[
https://issues.apache.org/jira/browse/KAFKA-9576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9576.
Resolution: Duplicate
> Topic creation failure causing Stream thread death
>
Boyang Chen created KAFKA-10097:
---
Summary: Avoid getting null map for task checkpoint
Key: KAFKA-10097
URL: https://issues.apache.org/jira/browse/KAFKA-10097
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-10087:
---
Summary: Properly throw LogTruncation exception from
OffsetForLeaderEpoch future
Key: KAFKA-10087
URL: https://issues.apache.org/jira/browse/KAFKA-10087
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10011.
-
Resolution: Fixed
> lockedTaskDirectories should be cleared when task gets closed dirty in
>
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10010.
-
Resolution: Fixed
> Should make state store registration idempotent
>
Boyang Chen created KAFKA-10064:
---
Summary: Add documentation for KIP-571
Key: KAFKA-10064
URL: https://issues.apache.org/jira/browse/KAFKA-10064
Project: Kafka
Issue Type: Task
Boyang Chen created KAFKA-10042:
---
Summary: Make INVALID_PRODUCER_EPOCH abortable from Produce
response
Key: KAFKA-10042
URL: https://issues.apache.org/jira/browse/KAFKA-10042
Project: Kafka
Boyang Chen created KAFKA-10011:
---
Summary: lockedTaskDirectories should be cleared when task gets
closed dirty in HandleLostAll
Key: KAFKA-10011
URL: https://issues.apache.org/jira/browse/KAFKA-10011
Boyang Chen created KAFKA-10010:
---
Summary: Should close standby task for safety during HandleLostAll
Key: KAFKA-10010
URL: https://issues.apache.org/jira/browse/KAFKA-10010
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7566.
Resolution: Won't Fix
> Add sidecar job to leader (or a random single follower) only
>
Boyang Chen created KAFKA-:
--
Summary: Topic description should be triggered after each failed
topic creation iteration
Key: KAFKA-
URL: https://issues.apache.org/jira/browse/KAFKA-
Project:
Boyang Chen created KAFKA-9994:
--
Summary: Catch TaskMigrated exception in task corruption code path
Key: KAFKA-9994
URL: https://issues.apache.org/jira/browse/KAFKA-9994
Project: Kafka
Issue
Boyang Chen created KAFKA-9993:
--
Summary: Think about inheritance in the protocol generation
framework
Key: KAFKA-9993
URL: https://issues.apache.org/jira/browse/KAFKA-9993
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9676.
Resolution: Fixed
The current unit test coverage is pretty good now, closing the ticket.
> Add
Boyang Chen created KAFKA-9989:
--
Summary: StreamsUpgradeTest.test_metadata_upgrade could not
guarantee all processor gets assigned task
Key: KAFKA-9989
URL: https://issues.apache.org/jira/browse/KAFKA-9989
[
https://issues.apache.org/jira/browse/KAFKA-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8989.
Resolution: Won't Fix
> Embedded broker could not be reached in unit test
>
Boyang Chen created KAFKA-9984:
--
Summary: Should fail the subscription when pattern is empty
Key: KAFKA-9984
URL: https://issues.apache.org/jira/browse/KAFKA-9984
Project: Kafka
Issue Type: Bug
Boyang Chen created KAFKA-9972:
--
Summary: Corrupted standby task could be committed
Key: KAFKA-9972
URL: https://issues.apache.org/jira/browse/KAFKA-9972
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8587.
Resolution: Fixed
> One producer per thread for Kafka Streams EOS
>
Boyang Chen created KAFKA-9910:
--
Summary: Implement new transaction timed out error
Key: KAFKA-9910
URL: https://issues.apache.org/jira/browse/KAFKA-9910
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9911:
--
Summary: Implement new producer fenced error
Key: KAFKA-9911
URL: https://issues.apache.org/jira/browse/KAFKA-9911
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8993.
Resolution: Won't Fix
> Add an EOS performance test suite similar to ProducerPerformance
>
Boyang Chen created KAFKA-9878:
--
Summary: Block EndTxn call until the txn markers are committed
Key: KAFKA-9878
URL: https://issues.apache.org/jira/browse/KAFKA-9878
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-8870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8870.
Resolution: Duplicate
> Prevent dirty reads of Streams state store from Interactive queries
>
[
https://issues.apache.org/jira/browse/KAFKA-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9764.
Resolution: Fixed
> Deprecate Stream Simple benchmark
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9793.
Resolution: Fixed
> Stream HandleAssignment should guarantee task close
>
Boyang Chen created KAFKA-9860:
--
Summary: Transactional Producer could add partitions by batch at
the end
Key: KAFKA-9860
URL: https://issues.apache.org/jira/browse/KAFKA-9860
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9784.
Resolution: Fixed
> Add OffsetFetch to the concurrent coordinator test
>
[
https://issues.apache.org/jira/browse/KAFKA-9809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9809.
Resolution: Fixed
> Shrink transaction timeout for Streams
>
Boyang Chen created KAFKA-9809:
--
Summary: Shrink transaction timeout for Streams
Key: KAFKA-9809
URL: https://issues.apache.org/jira/browse/KAFKA-9809
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9793:
--
Summary: Stream HandleAssignment should guarantee task close
Key: KAFKA-9793
URL: https://issues.apache.org/jira/browse/KAFKA-9793
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-9784:
--
Summary: Add OffsetFetch to the concurrent coordinator test
Key: KAFKA-9784
URL: https://issues.apache.org/jira/browse/KAFKA-9784
Project: Kafka
Issue Type:
Boyang Chen created KAFKA-9779:
--
Summary: Add version 2.5 to streams system tests
Key: KAFKA-9779
URL: https://issues.apache.org/jira/browse/KAFKA-9779
Project: Kafka
Issue Type: Improvement
Boyang Chen created KAFKA-9764:
--
Summary: Deprecate Stream Simple benchmark
Key: KAFKA-9764
URL: https://issues.apache.org/jira/browse/KAFKA-9764
Project: Kafka
Issue Type: Improvement
Boyang Chen created KAFKA-9760:
--
Summary: Add EOS protocol changes to documentation
Key: KAFKA-9760
URL: https://issues.apache.org/jira/browse/KAFKA-9760
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9759:
--
Summary: Add documentation change for KIP-562
Key: KAFKA-9759
URL: https://issues.apache.org/jira/browse/KAFKA-9759
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9758:
--
Summary: Add documentations for Streams release
Key: KAFKA-9758
URL: https://issues.apache.org/jira/browse/KAFKA-9758
Project: Kafka
Issue Type: Improvement
Boyang Chen created KAFKA-9757:
--
Summary: Add documentation change for KIP-535
Key: KAFKA-9757
URL: https://issues.apache.org/jira/browse/KAFKA-9757
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9475.
Resolution: Won't Fix
It seems not worth the effort as we could just shrink the scheduler time
>
[
https://issues.apache.org/jira/browse/KAFKA-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9743.
Resolution: Fixed
> StreamTask could fail to close during HandleNewAssignment
>
[
https://issues.apache.org/jira/browse/KAFKA-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8230.
Resolution: Fixed
Will be tracked on the librdKafka side, which seems to be done
> Add static
Boyang Chen created KAFKA-9751:
--
Summary: Admin `FindCoordinator` call should go to controller
instead of ZK
Key: KAFKA-9751
URL: https://issues.apache.org/jira/browse/KAFKA-9751
Project: Kafka
Boyang Chen created KAFKA-9743:
--
Summary: StreamTask could fail to close during HandleNewAssignment
Key: KAFKA-9743
URL: https://issues.apache.org/jira/browse/KAFKA-9743
Project: Kafka
Issue
1 - 100 of 312 matches
Mail list logo
