[
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 Stre
[
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 t
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-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9764.
Resolution: Fixed
> Deprecate Stream Simple benchm
[
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 cl
[
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 quer
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-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 ProducerPer
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
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
[
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
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
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
[
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 u
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-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.
>
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
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-:
--
Summary: Topic description should be triggered after each failed
topic creation iteration
Key: KAFKA-
URL: https://issues.apache.org/jira/browse/KAFKA-
Project
[
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 follow
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
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-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-10064:
---
Summary: Add documentation for KIP-571
Key: KAFKA-10064
URL: https://issues.apache.org/jira/browse/KAFKA-10064
Project: Kafka
Issue Type: Task
[
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 idempot
[
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
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
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
[
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 de
[
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 externa
Boyang Chen created KAFKA-9224:
--
Summary: State store should not see uncommitted transaction result
Key: KAFKA-9224
URL: https://issues.apache.org/jira/browse/KAFKA-9224
Project: Kafka
Issue
Boyang Chen created KAFKA-9274:
--
Summary: Gracefully handle timeout exceptions on Kafka Streams
Key: KAFKA-9274
URL: https://issues.apache.org/jira/browse/KAFKA-9274
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9346:
--
Summary: Consumer fetch offset back-off with pending transactions
Key: KAFKA-9346
URL: https://issues.apache.org/jira/browse/KAFKA-9346
Project: Kafka
Issue
Boyang Chen created KAFKA-9365:
--
Summary: Add consumer group information to producer txn commit
Key: KAFKA-9365
URL: https://issues.apache.org/jira/browse/KAFKA-9365
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9377:
--
Summary: Refactor StreamsPartitionAssignor Repartition Count logic
Key: KAFKA-9377
URL: https://issues.apache.org/jira/browse/KAFKA-9377
Project: Kafka
Issue
Boyang Chen created KAFKA-9378:
--
Summary: Revisit the sub-topology initialization logic
Key: KAFKA-9378
URL: https://issues.apache.org/jira/browse/KAFKA-9378
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9383:
--
Summary: Expose Consumer Group Metadata for Transactional Producer
Key: KAFKA-9383
URL: https://issues.apache.org/jira/browse/KAFKA-9383
Project: Kafka
Issue
Boyang Chen created KAFKA-9394:
--
Summary: Add partial success for Consumer offset fetch
Key: KAFKA-9394
URL: https://issues.apache.org/jira/browse/KAFKA-9394
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9417:
--
Summary: Add extension to the TransactionsTest.transactions_test
for new EOS model
Key: KAFKA-9417
URL: https://issues.apache.org/jira/browse/KAFKA-9417
Project: Kafka
Boyang Chen created KAFKA-9418:
--
Summary: Add new sendOffsets API to include consumer group metadata
Key: KAFKA-9418
URL: https://issues.apache.org/jira/browse/KAFKA-9418
Project: Kafka
Issue
Boyang Chen created KAFKA-9421:
--
Summary: Restricting access of commit for consumer member
Key: KAFKA-9421
URL: https://issues.apache.org/jira/browse/KAFKA-9421
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-9346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9346.
Resolution: Fixed
> Consumer fetch offset back-off with pending transacti
[
https://issues.apache.org/jira/browse/KAFKA-9365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9365.
Resolution: Fixed
> Add consumer group information to txn com
Boyang Chen created KAFKA-9439:
--
Summary: Add more public API tests for KafkaProducer
Key: KAFKA-9439
URL: https://issues.apache.org/jira/browse/KAFKA-9439
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9440:
--
Summary: Add ConsumerGroupCommand to delete static members
Key: KAFKA-9440
URL: https://issues.apache.org/jira/browse/KAFKA-9440
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9447:
--
Summary: Add examples for EOS standalone and group mode under
kafka/examples
Key: KAFKA-9447
URL: https://issues.apache.org/jira/browse/KAFKA-9447
Project: Kafka
Boyang Chen created KAFKA-9453:
--
Summary: Make transaction.id optional in group mode EOS
Key: KAFKA-9453
URL: https://issues.apache.org/jira/browse/KAFKA-9453
Project: Kafka
Issue Type: Sub
Boyang Chen created KAFKA-9454:
--
Summary: Relax transaction.id security requirement
Key: KAFKA-9454
URL: https://issues.apache.org/jira/browse/KAFKA-9454
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9466:
--
Summary: Add documentation for new stream EOS change
Key: KAFKA-9466
URL: https://issues.apache.org/jira/browse/KAFKA-9466
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9473:
--
Summary: A large number of core system tests failing due to Kafka
server failed to start on trunk
Key: KAFKA-9473
URL: https://issues.apache.org/jira/browse/KAFKA-9473
Boyang Chen created KAFKA-9475:
--
Summary: Replace transaction abortion scheduler with a delayed
queue
Key: KAFKA-9475
URL: https://issues.apache.org/jira/browse/KAFKA-9475
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9447.
Resolution: Fixed
> Add examples for EOS standalone and group mode under kafka/examp
Boyang Chen created KAFKA-9523:
--
Summary: Reduce flakiness of
BranchedMultiLevelRepartitionConnectedTopologyTest
Key: KAFKA-9523
URL: https://issues.apache.org/jira/browse/KAFKA-9523
Project: Kafka
Boyang Chen created KAFKA-9534:
--
Summary: Potential inconsistent result for listTopic talking to
older brokers
Key: KAFKA-9534
URL: https://issues.apache.org/jira/browse/KAFKA-9534
Project: Kafka
Boyang Chen created KAFKA-9535:
--
Summary: Metadata not updated when consumer encounters leader
epoch related failures
Key: KAFKA-9535
URL: https://issues.apache.org/jira/browse/KAFKA-9535
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8616.
Resolution: Duplicate
> Replace ApiVersionsRequest request/response with automated proto
Boyang Chen created KAFKA-9552:
--
Summary: Stream should handle OutOfSequence exception thrown from
Producer
Key: KAFKA-9552
URL: https://issues.apache.org/jira/browse/KAFKA-9552
Project: Kafka
Boyang Chen created KAFKA-9561:
--
Summary: Update task input partitions when topic metadata changes
Key: KAFKA-9561
URL: https://issues.apache.org/jira/browse/KAFKA-9561
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9545.
Resolution: Fixed
> Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDele
[
https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9473.
Resolution: Fixed
> A large number of core system tests failing due to Kafka server failed
Boyang Chen created KAFKA-9576:
--
Summary: Topic creation failure causing Stream thread death
Key: KAFKA-9576
URL: https://issues.apache.org/jira/browse/KAFKA-9576
Project: Kafka
Issue Type: Bug
Boyang Chen created KAFKA-9581:
--
Summary: Deprecate rebalanceException on StreamThread to avoid
infinite loop
Key: KAFKA-9581
URL: https://issues.apache.org/jira/browse/KAFKA-9581
Project: Kafka
Boyang Chen created KAFKA-9582:
--
Summary: Ensure EOS task producer not through fatal error in
unclean shutdown
Key: KAFKA-9582
URL: https://issues.apache.org/jira/browse/KAFKA-9582
Project: Kafka
Boyang Chen created KAFKA-9592:
--
Summary: Safely abort Producer transactions during application
shutdown
Key: KAFKA-9592
URL: https://issues.apache.org/jira/browse/KAFKA-9592
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9582.
Resolution: Fixed
> Ensure EOS task producer not through fatal error in unclean shutd
[
https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9441.
Resolution: Fixed
> Refactor commit logic
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9581.
Resolution: Fixed
> Deprecate rebalanceException on StreamThread to avoid infinite l
Boyang Chen created KAFKA-9602:
--
Summary: Incorrect close of producer instance during partition
assignment
Key: KAFKA-9602
URL: https://issues.apache.org/jira/browse/KAFKA-9602
Project: Kafka
Boyang Chen created KAFKA-9605:
--
Summary: EOS Producer could throw illegal state if trying to
complete a failed batch after fatal error
Key: KAFKA-9605
URL: https://issues.apache.org/jira/browse/KAFKA-9605
Boyang Chen created KAFKA-9607:
--
Summary: Should not clear partition group if the task will be
revived again
Key: KAFKA-9607
URL: https://issues.apache.org/jira/browse/KAFKA-9607
Project: Kafka
Boyang Chen created KAFKA-9608:
--
Summary: An EOS model simulation test
Key: KAFKA-9608
URL: https://issues.apache.org/jira/browse/KAFKA-9608
Project: Kafka
Issue Type: Improvement
Boyang Chen created KAFKA-9610:
--
Summary: Should not throw illegal state exception during task
revocation
Key: KAFKA-9610
URL: https://issues.apache.org/jira/browse/KAFKA-9610
Project: Kafka
Boyang Chen created KAFKA-9618:
--
Summary: Failed state store deletion could lead to task file not
found
Key: KAFKA-9618
URL: https://issues.apache.org/jira/browse/KAFKA-9618
Project: Kafka
Boyang Chen created KAFKA-9620:
--
Summary: Task revocation failure could introduce remaining unclean
tasks
Key: KAFKA-9620
URL: https://issues.apache.org/jira/browse/KAFKA-9620
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reopened KAFKA-8460:
> Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartit
Boyang Chen created KAFKA-9637:
--
Summary: Create separate state directory to manage locks
Key: KAFKA-9637
URL: https://issues.apache.org/jira/browse/KAFKA-9637
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9645:
--
Summary: Records could not find corresponding partition/task
Key: KAFKA-9645
URL: https://issues.apache.org/jira/browse/KAFKA-9645
Project: Kafka
Issue Type
Boyang Chen created KAFKA-9657:
--
Summary: Add configurable throw on unsupported protocol
Key: KAFKA-9657
URL: https://issues.apache.org/jira/browse/KAFKA-9657
Project: Kafka
Issue Type: Sub
Boyang Chen created KAFKA-9666:
--
Summary: Transactional producer Epoch could not be reset
Key: KAFKA-9666
URL: https://issues.apache.org/jira/browse/KAFKA-9666
Project: Kafka
Issue Type: Bug
Boyang Chen created KAFKA-9674:
--
Summary: Task corruption should also close the producer if
necessary
Key: KAFKA-9674
URL: https://issues.apache.org/jira/browse/KAFKA-9674
Project: Kafka
Issue
Boyang Chen created KAFKA-9676:
--
Summary: Add test coverage for new ActiveTaskCreator and
StandbyTaskCreator
Key: KAFKA-9676
URL: https://issues.apache.org/jira/browse/KAFKA-9676
Project: Kafka
Boyang Chen created KAFKA-9679:
--
Summary: Mock consumer should behave consistent with actual
consumer
Key: KAFKA-9679
URL: https://issues.apache.org/jira/browse/KAFKA-9679
Project: Kafka
Issue
Boyang Chen created KAFKA-9689:
--
Summary: Automatic broker version detection to initialize stream
client
Key: KAFKA-9689
URL: https://issues.apache.org/jira/browse/KAFKA-9689
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9674.
Resolution: Fixed
> Task corruption should also close the producer if necess
[
https://issues.apache.org/jira/browse/KAFKA-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9618.
Resolution: Fixed
> Failed state store deletion could lead to task file not fo
[
https://issues.apache.org/jira/browse/KAFKA-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9562.
Resolution: Fixed
> Streams not making progress under heavy failures with EOS enabled on
Boyang Chen created KAFKA-9701:
--
Summary: Consumer could catch InconsistentGroupProtocolException
during rebalance
Key: KAFKA-9701
URL: https://issues.apache.org/jira/browse/KAFKA-9701
Project: Kafka
Boyang Chen created KAFKA-9705:
--
Summary: (Incremental)AlterConfig should be propagated from
Controller in bridge release
Key: KAFKA-9705
URL: https://issues.apache.org/jira/browse/KAFKA-9705
Project
[
https://issues.apache.org/jira/browse/KAFKA-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9657.
Resolution: Fixed
> Add configurable throw on unsupported proto
Boyang Chen created KAFKA-9719:
--
Summary: Add Integration Test For ensuring the EOS-beta app would
crash with broker downgrade
Key: KAFKA-9719
URL: https://issues.apache.org/jira/browse/KAFKA-9719
Boyang Chen created KAFKA-9727:
--
Summary: Flaky system test StreamsEOSTest.test_failure_and_recovery
Key: KAFKA-9727
URL: https://issues.apache.org/jira/browse/KAFKA-9727
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reopened KAFKA-8122:
Assignee: (was: Matthias J. Sax)
> Flaky Test EosIntegrationT
[
https://issues.apache.org/jira/browse/KAFKA-9727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9727.
Resolution: Fixed
> Flaky system test StreamsEOSTest.test_failure_and_recov
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-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-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-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-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
[
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
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
601 - 700 of 720 matches
Mail list logo
