[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8715:
---
Component/s: streams
consumer
> Static consumer cannot join group due to ERROR in br
[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8715:
---
Labels: blocker (was: )
> Static consumer cannot join group due to ERROR in broker
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894041#comment-16894041
]
Boyang Chen commented on KAFKA-8686:
[https://builds.apache.org/job/kafka-pr-jdk8-sca
Boyang Chen created KAFKA-8720:
--
Summary: Flakey test AdminClientIntegrationTest
#testElectUncleanLeadersForManyPartitions
Key: KAFKA-8720
URL: https://issues.apache.org/jira/browse/KAFKA-8720
Project:
[
https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894153#comment-16894153
]
Boyang Chen commented on KAFKA-8672:
[https://builds.apache.org/job/kafka-pr-jdk8-sca
[
https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894153#comment-16894153
]
Boyang Chen edited comment on KAFKA-8672 at 7/26/19 9:43 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894155#comment-16894155
]
Boyang Chen commented on KAFKA-8672:
[https://builds.apache.org/job/kafka-pr-jdk11-sc
Boyang Chen created KAFKA-8723:
--
Summary: flaky test LeaderElectionCommandTest#testAllTopicPartition
Key: KAFKA-8723
URL: https://issues.apache.org/jira/browse/KAFKA-8723
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894590#comment-16894590
]
Boyang Chen commented on KAFKA-8555:
[https://builds.apache.org/job/kafka-pr-jdk8-sca
[
https://issues.apache.org/jira/browse/KAFKA-8435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8435.
Resolution: Fixed
> Replace DeleteGroups request/response with automated protocol
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894745#comment-16894745
]
Boyang Chen commented on KAFKA-8672:
[https://builds.apache.org/job/kafka-pr-jdk11-sc
[
https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894782#comment-16894782
]
Boyang Chen commented on KAFKA-8460:
*https://builds.apache.org/job/kafka-pr-jdk8-sca
[
https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895489#comment-16895489
]
Boyang Chen commented on KAFKA-4222:
[https://builds.apache.org/job/kafka-pr-jdk8-sca
[
https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895491#comment-16895491
]
Boyang Chen commented on KAFKA-8661:
[https://builds.apache.org/job/kafka-pr-jdk11-sc
[
https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895492#comment-16895492
]
Boyang Chen commented on KAFKA-8677:
[https://builds.apache.org/job/kafka-pr-jdk8-sca
[
https://issues.apache.org/jira/browse/KAFKA-8748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16903340#comment-16903340
]
Boyang Chen commented on KAFKA-8748:
[https://builds.apache.org/job/kafka-pr-jdk11-sc
[
https://issues.apache.org/jira/browse/KAFKA-8773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16903390#comment-16903390
]
Boyang Chen commented on KAFKA-8773:
Thanks for reporting the bug [~rocketraman]. In
Boyang Chen created KAFKA-8785:
--
Summary: Flakey test LeaderElectionCommandTest#testPathToJsonFile
Key: KAFKA-8785
URL: https://issues.apache.org/jira/browse/KAFKA-8785
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923636#comment-16923636
]
Boyang Chen commented on KAFKA-6461:
[https://builds.apache.org/job/kafka-pr-jdk8-sca
[
https://issues.apache.org/jira/browse/KAFKA-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8222.
Resolution: Fixed
> Admin client changes to add ability to batch remove static members
> --
[
https://issues.apache.org/jira/browse/KAFKA-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7018.
Fix Version/s: 2.4.0
Resolution: Fixed
> persist memberId for consumer restart
> ---
Boyang Chen created KAFKA-8972:
--
Summary: Reduce
streams_broker_bounce_test.py#test_broker_type_bounce flakiness
Key: KAFKA-8972
URL: https://issues.apache.org/jira/browse/KAFKA-8972
Project: Kafka
Boyang Chen created KAFKA-8973:
--
Summary: Give user options to turn off linger.ms/batch.size
constraint
Key: KAFKA-8973
URL: https://issues.apache.org/jira/browse/KAFKA-8973
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944806#comment-16944806
]
Boyang Chen commented on KAFKA-8970:
Thanks for the report Nishkam. I suspect your un
Boyang Chen created KAFKA-8989:
--
Summary: Embedded broker could not be reached in unit test
Key: KAFKA-8989
URL: https://issues.apache.org/jira/browse/KAFKA-8989
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946232#comment-16946232
]
Boyang Chen commented on KAFKA-8973:
I guess it's not an action item that makes sense
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Summary: Toggle bulkloading hit NPE (was: Reduce
streams_broker_bounce_test.py#test_broker_type_boun
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Description:
test `test_broker_type_bounce` could sometimes fail due to NPE in changelog
restoration
Boyang Chen created KAFKA-8993:
--
Summary: Add an EOS performance test suite similar to
ProducerPerformance
Key: KAFKA-8993
URL: https://issues.apache.org/jira/browse/KAFKA-8993
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-8432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-8432:
--
Assignee: (was: Boyang Chen)
> Add static membership to Sticky assignor
>
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Priority: Blocker (was: Major)
> Toggle bulkloading hit NPE
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Fix Version/s: 2.4.0
> Toggle bulkloading hit NPE
> --
>
> Ke
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8972:
---
Affects Version/s: 2.4.0
> Toggle bulkloading hit NPE
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8973.
Resolution: Won't Fix
> Give user options to turn off linger.ms/batch.size constraint
> ---
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 Typ
[
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 KTableSourceTopicRestartIntegrationTest
> #shouldRestore
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
Issue
[
https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9075:
---
Labels: newbie newbie++ (was: )
> 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 updated KAFKA-9075:
---
Description:
We have a KIP which implements global KTable and explains its design reasoning
and comp
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16956439#comment-16956439
]
Boyang Chen commented on KAFKA-9062:
[~ableegoldman] Could you provide more details o
[
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 KTable
>
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16957416#comment-16957416
]
Boyang Chen commented on KAFKA-9062:
That's a good suggestion, we should try to utili
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
Proj
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:
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959244#comment-16959244
]
Boyang Chen commented on KAFKA-6453:
Need to have both state store section and DSL se
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959246#comment-16959246
]
Boyang Chen commented on KAFKA-6453:
Executor needs to first check in change into the
[
https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961544#comment-16961544
]
Boyang Chen commented on KAFKA-8972:
A status update: [~ableegoldman] found the last
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
[
https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9112:
---
Component/s: streams
> Combine streams `onAssignment` with `partitionsAssigned` task creation
> -
[
https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8677:
---
Priority: Blocker (was: Major)
> Flakey test
> GroupEndToEndAuthorizationTest#testNoDescribeProduce
[
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
> state
> ---
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:
[
https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968797#comment-16968797
]
Boyang Chen commented on KAFKA-9148:
If we gave user the option to use either fRocksD
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969488#comment-16969488
]
Boyang Chen commented on KAFKA-8803:
You mean [~timvanlaer] transaction coordinator r
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
[
https://issues.apache.org/jira/browse/KAFKA-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9178:
---
Labels: streams (was: )
> Streams changelog topics are not cleaning up during lost task closing
> --
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 Typ
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983504#comment-16983504
]
Boyang Chen commented on KAFKA-8803:
[~rocketraman] Hey Raman, I'm currently investig
[
https://issues.apache.org/jira/browse/KAFKA-8773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983506#comment-16983506
]
Boyang Chen commented on KAFKA-8773:
Hey Raman, wondering whether you got a fix for t
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984069#comment-16984069
]
Boyang Chen commented on KAFKA-8803:
[~rocketraman] Thanks, so the issue happens spon
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984073#comment-16984073
]
Boyang Chen commented on KAFKA-8803:
To be more specific, quoted from [~hachikuji]:
[
https://issues.apache.org/jira/browse/KAFKA-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16301556#comment-16301556
]
Boyang Chen commented on KAFKA-6386:
Hi I'm new to Kafka repo and would like to contri
[
https://issues.apache.org/jira/browse/KAFKA-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302157#comment-16302157
]
Boyang Chen commented on KAFKA-6386:
Thanks a lot Guozhang! [~guozhang]
> Deprecate K
[
https://issues.apache.org/jira/browse/KAFKA-6363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16303641#comment-16303641
]
Boyang Chen commented on KAFKA-6363:
[~h314to] Hello man, do you still want to work on
[
https://issues.apache.org/jira/browse/KAFKA-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-6381:
--
Assignee: Boyang Chen
> Improve KafkaStreamsTest for localThreadMetadata
>
[
https://issues.apache.org/jira/browse/KAFKA-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16303758#comment-16303758
]
Boyang Chen commented on KAFKA-6381:
I shall take a look on this one :) @mjsax
> Impr
[
https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078421#comment-17078421
]
Boyang Chen commented on KAFKA-9592:
[~iamabug] Thanks for the check. I think the cod
[
https://issues.apache.org/jira/browse/KAFKA-9840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9840:
--
Assignee: Boyang Chen
> Consumer should not use OffsetForLeaderEpoch without current epoch val
[
https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079982#comment-17079982
]
Boyang Chen commented on KAFKA-9592:
[~iamabug] I synced with [~guozhang] offline abo
[
https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080007#comment-17080007
]
Boyang Chen commented on KAFKA-9765:
[~waykarp] Is your broker also on 2.3?
> Could
[
https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080187#comment-17080187
]
Boyang Chen commented on KAFKA-9765:
Thanks, I checked the broker side code and the l
[
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-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080274#comment-17080274
]
Boyang Chen commented on KAFKA-9592:
[~iamabug] Yes, I think your understanding is co
[
https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082409#comment-17082409
]
Boyang Chen commented on KAFKA-9859:
Thanks for reporting. From your observation, is
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
Is
[
https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9860:
---
Description:
As of today, the Producer transaction manager bookkeeps the partitions involved
with cu
[
https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082518#comment-17082518
]
Boyang Chen commented on KAFKA-9850:
Thanks for the reporting, do you want to pick th
[
https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082806#comment-17082806
]
Boyang Chen commented on KAFKA-9592:
My expectation is that your mentioned exceptions
[
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
> -
[
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-9608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9608:
---
Description: We want to build a framework which could generate random
events to process a simple EOS
[
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-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084191#comment-17084191
]
Boyang Chen commented on KAFKA-9592:
[~iamabug] Could you phrase the new comment for
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: I
[
https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9860:
---
Summary: Transactional Producer could pre-add partitions (was:
Transactional Producer could add part
[
https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9860:
---
Description:
As of today, the Producer transaction manager bookkeeps the partitions involved
with cu
[
https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9860:
---
Labels: need-kip (was: )
> Transactional Producer could pre-add partitions
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9860:
---
Component/s: producer
> Transactional Producer could pre-add partitions
> --
[
https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9860:
--
Assignee: (was: Boyang Chen)
> Transactional Producer could pre-add partitions
> -
[
https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9224:
---
Description: Currently under EOS, the uncommitted write could be reflected
in the state store before
[
https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085163#comment-17085163
]
Boyang Chen commented on KAFKA-9224:
[~vvcephei] [~guozhang]Yea, it's a typo, and I j
[
https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9860:
---
Description:
As of today, the Producer transaction manager bookkeeps the partitions involved
with cu
[
https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086127#comment-17086127
]
Boyang Chen commented on KAFKA-9224:
This basically goes back to what consistency gua
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-9520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087896#comment-17087896
]
Boyang Chen commented on KAFKA-9520:
[~cmccabe] Is this fixed?
> Deprecate ZooKeeper
[
https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9850:
---
Labels: help-wanted newbie newbie++ (was: )
> Move KStream#repartition operator validation during To
[
https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087971#comment-17087971
]
Boyang Chen commented on KAFKA-9850:
[~lkokhreidze] Since you haven't got a chance to
[
https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087999#comment-17087999
]
Boyang Chen commented on KAFKA-9868:
[~ableegoldman]Do we have the failure log?
> Fl
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088044#comment-17088044
]
Boyang Chen commented on KAFKA-9891:
Thanks for the report, will take a look this wee
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9891:
--
Assignee: Boyang Chen
> Invalid state store content after task migration with exactly_once and
501 - 600 of 958 matches
Mail list logo
