[jira] [Created] (KAFKA-9751) Admin `FindCoordinator` call should go to controller instead of ZK

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

Re: [DISCUSS] KIP-580: Exponential Backoff for Kafka Clients

;> That > >>>>>>>> makes sense if you assume the user is unaware of the new > >>>>> configuration, > >>>>>>> but > >>>>>>>> it is surprising otherwise. Since it's not a semantic change > >>

[jira] [Created] (KAFKA-9743) StreamTask could fail to close during HandleNewAssignment

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

Re: [VOTE] 2.5.0 RC2

Hey David, I would like to raise https://issues.apache.org/jira/browse/KAFKA-9701 as a 2.5 blocker. The impact of this bug is that it could throw fatal exception and kill a stream thread on Kafka Streams level. It could also create a crashing scenario for plain Kafka Consumer users as well as the

[jira] [Resolved] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

[ 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

Re: 回复：回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

think it makes sense to > encapsulate the "get and delete" logic in adminClient. I will update the > KIP shortly! > > Thanks! > > Feyman > > > -- > 发件人：Boyang Chen > 发送时间：2020年3月14日(星期六) 0

[jira] [Reopened] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

[ 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

Re: [DISCUSS] KIP-580: Exponential Backoff for Kafka Clients

xample to the KIP and flush out more of the details - so it’s more clear. On Mar 17, 2020, 1:24 PM -0700, Boyang Chen , wrote: > Thanks for the reply Sanjana. I guess I would like to rephrase my question > 2 and 3 as my previous response is a little bit unactionable. > > My specific point i

Re: [DISCUSS] KIP-580: Exponential Backoff for Kafka Clients

with respect to > client timeouts? I’m not very familiar with the Streams framework, so would > love to get more insight to how that currently works, with respect to > producer transactions, so I can appropriately update the KIP to address > these scenarios. > On Mar 13, 2020, 7:15

[jira] [Created] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

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

Re: [DISCUSS] KIP-580: Exponential Backoff for Kafka Clients

Thanks for the KIP Sanjana. I think the motivation is good, but lack of more quantitative analysis. For instance: 1. How much retries we are saving by applying the exponential retry vs static retry? There should be some mathematical relations between the static retry ms, the initial exponential

Re: 回复：回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

, the > > >>>> "removeMembersFromConsumerGroup" only sends a leave-group > > >>>> request to the coordinator to let it remove the member, > > >>>> however, if the member is still there alive and running then it > > >>&

[jira] [Created] (KAFKA-9719) Add Integration Test For ensuring the EOS-beta app would crash with broker downgrade

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

[jira] [Resolved] (KAFKA-9657) Add configurable throw on unsupported protocol

[ 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

[jira] [Created] (KAFKA-9705) (Incremental)AlterConfig should be propagated from Controller in bridge release

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

[jira] [Created] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

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

[jira] [Resolved] (KAFKA-9562) Streams not making progress under heavy failures with EOS enabled on 2.5 branch

[ 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

[jira] [Resolved] (KAFKA-9674) Task corruption should also close the producer if necessary

[ 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

[jira] [Resolved] (KAFKA-9618) Failed state store deletion could lead to task file not found

[ 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

[jira] [Created] (KAFKA-9689) Automatic broker version detection to initialize stream client

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

[jira] [Created] (KAFKA-9679) Mock consumer should behave consistent with actual consumer

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

[jira] [Created] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

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

[jira] [Created] (KAFKA-9674) Task corruption should also close the producer if necessary

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

[jira] [Created] (KAFKA-9666) Transactional producer Epoch could not be reset

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

[jira] [Created] (KAFKA-9657) Add configurable throw on unsupported protocol

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

[jira] [Created] (KAFKA-9645) Records could not find corresponding partition/task

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

[jira] [Created] (KAFKA-9637) Create separate state directory to manage locks

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

Add a customized logo for Kafka Streams

Hey Apache Kafka committers and community folks, over the years Kafka Streams has been widely adopted and tons of blog posts and tech talks have been trying to introduce it to people with need of stream processing. As it is part of Apache Kafka project, there is always an awkward situation where

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ 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

[jira] [Created] (KAFKA-9620) Task revocation failure could introduce remaining unclean tasks

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

Re: 回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

Thanks Feyman, +1 (non-binding) On Thu, Feb 27, 2020 at 9:25 AM John Roesler wrote: > Thanks for the proposal! > > I'm +1 (binding) > -John > > On Wed, Feb 26, 2020, at 19:41, feyman2009 wrote: > > Updated with the KIP link: > > >

[jira] [Created] (KAFKA-9618) Failed state store deletion could lead to task file not found

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

Re: [ANNOUNCE] New committer: Konstantine Karantasis

Congrats Konstantine！ On Wed, Feb 26, 2020 at 6:32 PM Manikumar wrote: > Congrats Konstantine! > On Thu, Feb 27, 2020 at 7:46 AM Matthias J. Sax wrote: > > > -BEGIN PGP SIGNED MESSAGE- > > Hash: SHA512 > > > > Congrats! > > > > On 2/27/20 2:21 AM, Jeremy Custenborder wrote: > > >

Re: Discussion thread for KIP-X

is the bottleneck, or some cost wise concern of over-partitioning. Boyang On Fri, Feb 21, 2020 at 10:44 AM Guozhang Wang mailto:wangg...@gmail.com>> wrote: > cc @Boyang Chen mailto:bche...@outlook.com>> who > authored this draft. > > > Guozhang > > On Fri, Feb 21,

[jira] [Created] (KAFKA-9610) Should not throw illegal state exception during task revocation

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

[jira] [Created] (KAFKA-9608) An EOS model simulation test

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

[jira] [Created] (KAFKA-9607) Should not clear partition group if the task will be revived again

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

[jira] [Created] (KAFKA-9605) EOS Producer could throw illegal state if trying to complete a failed batch after fatal error

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

[jira] [Created] (KAFKA-9602) Incorrect close of producer instance during partition assignment

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

[jira] [Resolved] (KAFKA-9581) Deprecate rebalanceException on StreamThread to avoid infinite loop

[ 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

Re: [Discuss] KIP-571: Add option to force remove members in StreamsResetter

ship+protocol+to+reduce+consumer+rebalances> > for > details). > If it is used upon the older clusters like 2.3, > *UnsupportedVersionException > *will be thrown. > > Thanks! > Haoran > > --

[jira] [Resolved] (KAFKA-9441) Refactor commit logic

[ 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 > - > >

[jira] [Resolved] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

[ 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

Re: Discussion thread for KIP-X

is the bottleneck, or some cost wise concern of over-partitioning. Boyang On Fri, Feb 21, 2020 at 10:44 AM Guozhang Wang wrote: > cc @Boyang Chen who authored this draft. > > > Guozhang > > On Fri, Feb 21, 2020 at 10:29 AM Rangan Prabhakaran (BLOOMBERG/ 919 3RD A) > < > kprabh

[jira] [Created] (KAFKA-9592) Safely abort Producer transactions during application shutdown

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

[jira] [Created] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

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

[jira] [Created] (KAFKA-9581) Deprecate rebalanceException on StreamThread to avoid infinite loop

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

[jira] [Created] (KAFKA-9576) Topic creation failure causing Stream thread death

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

[jira] [Resolved] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

[ 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 fai

Re: [Discuss] KIP-571: Add option to force remove members in StreamsResetter

away, or will it potentially leave the app in a partially reset state? > > Thanks! > Sophie > > On Tue, Feb 18, 2020 at 4:30 PM Boyang Chen > wrote: > > > Thanks for the update Feyman. The updates look great, except one thing I > > would like to be more specific is

Re: [Discuss] KIP-571: Add option to force remove members in StreamsResetter

at advices! > I have updated the KIP-571 , would you mind to see if it looks good ? > Thanks ! > > ------ > 发件人：Boyang Chen > 发送时间：2020年2月14日(星期五) 08:35 > 收件人：dev ; feyman2009 > 主 题：Re: [Discuss] KIP-571:

[jira] [Resolved] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

[ 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

[jira] [Created] (KAFKA-9561) Update task input partitions when topic metadata changes

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

Re: [VOTE] KIP-568: Explicit rebalance triggering on the Consumer

+1 (non-binding) On Thu, Feb 13, 2020 at 4:45 PM Guozhang Wang wrote: > +1 (binding). > > > Guozhang > > On Tue, Feb 11, 2020 at 5:29 PM Guozhang Wang wrote: > > > Hi Sophie, > > > > Thanks for the KIP, I left some comments on the DISCUSS thread. > > > > > > Guozhang > > > > > > On Tue, Feb

Re: [Discuss] KIP-571: Add option to force remove members in StreamsResetter

Thanks for driving this change Feyman! Hope this is a good name to call you :) The motivation of the KIP looks good, and I have a couple of initial thoughts: 1. I guess the reason to use setters instead of adding a new constructor to MemberToRemove class is because we have two String members.

[jira] [Created] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

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

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Goldman > > > wrote: > > > > > Hey Boyang, > > > > > > Originally I had it as a nonblocking call, but decided to change it to > > > blocking > > > with a timeout parameter. I'm not sure a future makes sense to return > > here, > &g

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Hey Sophie, is the `enforceRebalance` a blocking call? Could we add a code sample to the KIP on how this API should be used? Returning a future instead of a boolean might be easier as we are allowing consumer to make progress during rebalance after 429 IMHO. Boyang On Tue, Feb 11, 2020 at

Re: [VOTE] KIP-447: Producer scalability for exactly once semantics

pending offset fetch wait time. Let me know if you have further questions, thanks! On Wed, Jan 8, 2020 at 3:44 PM Boyang Chen wrote: > Thanks Guozhang for another review! I have addressed all the javadoc > changes for PendingTransactionException in the KIP. For FENCED_INSTANCE_ID >

[jira] [Resolved] (KAFKA-8616) Replace ApiVersionsRequest request/response with automated protocol

[ 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

[jira] [Created] (KAFKA-9535) Metadata not updated when consumer encounters leader epoch related failures

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

[jira] [Created] (KAFKA-9534) Potential inconsistent result for listTopic talking to older brokers

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

[jira] [Created] (KAFKA-9523) Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest

Boyang Chen created KAFKA-9523: -- Summary: Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest Key: KAFKA-9523 URL: https://issues.apache.org/jira/browse/KAFKA-9523 Project: Kafka

[jira] [Resolved] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

[ 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

[jira] [Created] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

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

[jira] [Created] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

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

Re: KIP-560 Discuss

Thanks Sophie for the explanation! I read Sang's PR and basically he did exactly what you proposed (check it here in case I'm wrong). I think Sophie's response answers Gwen's question already, while in the meantime for a KIP itself we are not

[jira] [Created] (KAFKA-9466) Add documentation for new stream EOS change

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

[jira] [Created] (KAFKA-9454) Relax transaction.id security requirement

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

[jira] [Created] (KAFKA-9453) Make transaction.id optional in group mode EOS

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

Re: [VOTE] KIP-560: Auto infer external topic partitions in stream reset tool

Hey Sang, thanks so much for driving this effort. I have just a couple of suggestions and questions: 1. In the Motivation part, would be better to phrase "user has to specify `--input-topic` in the stream reset to be able to reset offset to a specific position" as "user has to specify input

[jira] [Created] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

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

[jira] [Created] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

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

[jira] [Created] (KAFKA-9439) Add more public API tests for KafkaProducer

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

[jira] [Resolved] (KAFKA-9365) Add consumer group information to txn commit

[ 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

[jira] [Resolved] (KAFKA-9346) Consumer fetch offset back-off with pending transactions

[ 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

[jira] [Created] (KAFKA-9421) Restricting access of commit for consumer member

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

[jira] [Created] (KAFKA-9418) Add new sendOffsets API to include consumer group metadata

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

[jira] [Created] (KAFKA-9417) Add extension to the TransactionsTest.transactions_test for new EOS model

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

[jira] [Created] (KAFKA-9394) Add partial success for Consumer offset fetch

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

Re: [VOTE] KIP-447: Producer scalability for exactly once semantics

t; keeping) UPGRADE_FROM config to 2.4 (what might not be an ideal solution > and might also not be clear by itself that people would need to do this)? > > > Yes exactly, at the moment we are actively working on a plan to acquire broker's IBP during stream start-up and initialize based off that i

[jira] [Created] (KAFKA-9383) Expose Consumer Group Metadata for Transactional Producer

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

[jira] [Created] (KAFKA-9378) Revisit the sub-topology initialization logic

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

[jira] [Created] (KAFKA-9377) Refactor StreamsPartitionAssignor Repartition Count logic

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

[jira] [Created] (KAFKA-9365) Add consumer group information to producer txn commit

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

[jira] [Created] (KAFKA-9346) Consumer fetch offset back-off with pending transactions

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

[jira] [Created] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

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

[jira] [Created] (KAFKA-9224) State store should not see uncommitted transaction result

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

Re: doubt in kafka

Hey Rajesh, Consumer has a self managed assign mode to read from the topic you choose. Boyang Get Outlook for iOS From: Rakesh Reddy Donti Reddy Sent: Saturday, November 16, 2019 10:36:50 PM To: dev@kafka.apache.org Subject: doubt in

[jira] [Created] (KAFKA-9178) Streams changelog topics are not cleaning up during lost task closing

Boyang Chen created KAFKA-9178: -- Summary: Streams changelog topics are not cleaning up during lost task closing Key: KAFKA-9178 URL: https://issues.apache.org/jira/browse/KAFKA-9178 Project: Kafka

Re: [ANNOUNCE] New committer: John Roesler

Great work John! Well deserved On Tue, Nov 12, 2019 at 1:56 PM Guozhang Wang wrote: > Hi Everyone, > > The PMC of Apache Kafka is pleased to announce a new Kafka committer, John > Roesler. > > John has been contributing to Apache Kafka since early 2018. His main > contributions are primarily

[jira] [Created] (KAFKA-9146) Add option to force delete members in stream reset tool

Boyang Chen created KAFKA-9146: -- Summary: Add option to force delete members in stream reset tool Key: KAFKA-9146 URL: https://issues.apache.org/jira/browse/KAFKA-9146 Project: Kafka Issue Type

[jira] [Reopened] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-8972: > KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback >

[jira] [Created] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

Boyang Chen created KAFKA-9112: -- Summary: Combine streams `onAssignment` with `partitionsAssigned` task creation Key: KAFKA-9112 URL: https://issues.apache.org/jira/browse/KAFKA-9112 Project: Kafka

[jira] [Created] (KAFKA-9090) LeaveGroup admin request should enforce minimum version

Boyang Chen created KAFKA-9090: -- Summary: LeaveGroup admin request should enforce minimum version Key: KAFKA-9090 URL: https://issues.apache.org/jira/browse/KAFKA-9090 Project: Kafka Issue Type

[jira] [Created] (KAFKA-9085) Admin client should propagate UnsupportedVersion exception to user instead of crashing

Boyang Chen created KAFKA-9085: -- Summary: Admin client should propagate UnsupportedVersion exception to user instead of crashing Key: KAFKA-9085 URL: https://issues.apache.org/jira/browse/KAFKA-9085

[jira] [Resolved] (KAFKA-9075) Create FAQ documentation for usage of GlobalKTable vs KTable

[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9075. Resolution: Not A Problem > Create FAQ documentation for usage of GlobalKTable vs KTa

[jira] [Created] (KAFKA-9075) Create FAQ documentation for usage of GlobalKTable vs KTable

Boyang Chen created KAFKA-9075: -- Summary: Create FAQ documentation for usage of GlobalKTable vs KTable Key: KAFKA-9075 URL: https://issues.apache.org/jira/browse/KAFKA-9075 Project: Kafka

[jira] [Resolved] (KAFKA-8728) Flaky Test KTableSourceTopicRestartIntegrationTest #shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosDisabled

[ https://issues.apache.org/jira/browse/KAFKA-8728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8728. Resolution: Cannot Reproduce > Flaky Test KTableSourceTopicRestartIntegrationT

[jira] [Created] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

Boyang Chen created KAFKA-9042: -- Summary: Auto infer external topic partitions in stream reset tool Key: KAFKA-9042 URL: https://issues.apache.org/jira/browse/KAFKA-9042 Project: Kafka Issue

<    1   2   3   4   5   6   7   8   >