[
https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142429#comment-17142429
]
Boyang Chen commented on KAFKA-10055:
-
Need to move to the shared utility class as well
> Add
[
https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142429#comment-17142429
]
Boyang Chen edited comment on KAFKA-10055 at 6/22/20, 9:32 PM:
---
Need to
Boyang Chen created KAFKA-10192:
---
Summary: Flaky test BlockingConnectorTest#testBlockInConnectorStop
Key: KAFKA-10192
URL: https://issues.apache.org/jira/browse/KAFKA-10192
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139955#comment-17139955
]
Boyang Chen commented on KAFKA-10185:
-
Could we add the context to this ticket?
> Streams should
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
>
[
https://issues.apache.org/jira/browse/KAFKA-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136292#comment-17136292
]
Boyang Chen commented on KAFKA-10168:
-
[~sbellapu] There is already a WIP PR for this change
>
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
After some discussion we believe there is room to improve the accuracy of this
test,
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Summary: Wait for stable assignment
StreamsUpgradeTest.test_metadata_upgrade (was:
[
https://issues.apache.org/jira/browse/KAFKA-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135011#comment-17135011
]
Boyang Chen commented on KAFKA-9953:
Thanks for reporting the use case [~jwijgerd] . At a minimum,
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:
[
https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10135:
Component/s: streams
> Extract Task#executeAndMaybeSwallow to be a general utility function into
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
[
https://issues.apache.org/jira/browse/KAFKA-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10130:
Component/s: protocol
core
> Rewrite ZkData struct with auto-generated protocol
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-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129615#comment-17129615
]
Boyang Chen commented on KAFKA-10126:
-
I don't think we could remove options unless in a breaking
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10126:
Component/s: tools
consumer
> Remove unused options in ConsumerPerformance
>
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10126:
Issue Type: Improvement (was: Bug)
> Remove unused options in ConsumerPerformance
>
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128656#comment-17128656
]
Boyang Chen commented on KAFKA-6435:
Thanks for confirming! [~JoelWee] Do you think our discussion
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127880#comment-17127880
]
Boyang Chen commented on KAFKA-6435:
I would prefer we reach agreement on the approach here, before
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127684#comment-17127684
]
Boyang Chen commented on KAFKA-6435:
[~JoelWee] Thanks for your interest! Feel free to take it, but
[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10097:
Summary: Avoid passing task checkpoint file externally (was: Avoid getting
null map for task
[
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-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126890#comment-17126890
]
Boyang Chen commented on KAFKA-9377:
[~feyman] np, take your time!
> Refactor
[
https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126166#comment-17126166
]
Boyang Chen commented on KAFKA-9377:
[~feyman] Hey I'm assigning this ticket to you. A little bit
[
https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9377:
--
Assignee: feyman (was: Boyang Chen)
> Refactor StreamsPartitionAssignor Repartition Count
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126001#comment-17126001
]
Boyang Chen commented on KAFKA-10097:
-
[~feyman] Thank you for the interest! Unfortunately this
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125457#comment-17125457
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] I see, glad you guys have a workaround. I
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-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10087:
Description:
For OffsetForLeaderEpoch#onSuccess, we could throw either OffsetOutOfRange or
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-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124296#comment-17124296
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] that's right, so we should only check
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121149#comment-17121149
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] If we commit keyOne, then it *should* be
[
https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10055:
Summary: Add shared internal utility class for Streams module (was: Add
shared internal utility
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119899#comment-17119899
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] I ran your example again, and could see that
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-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9878:
--
Assignee: HaiyuanZhao
> Block AddPartitionsToTxn call until the txn markers are committed
>
[
https://issues.apache.org/jira/browse/KAFKA-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9561:
---
Fix Version/s: 2.6.0
> Update task input partitions when topic metadata changes
>
[
https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9146:
---
Fix Version/s: 2.6.0
> Add option to force delete members in stream reset tool
>
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
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9878:
---
Component/s: producer
core
> Block AddPartitionsToTxn call until the txn markers
[
https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10038:
Component/s: consumer
> ConsumerPerformance.scala supports the setting of client.id
>
[
https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10038:
Labels: newbie performance (was: performance)
> ConsumerPerformance.scala supports the setting
[
https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10036:
Labels: newbie (was: )
> Improve error message is user violates `Supplier` pattern
>
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114862#comment-17114862
]
Boyang Chen commented on KAFKA-9891:
I made another attempt to reproduce the issue on local.
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114811#comment-17114811
]
Boyang Chen edited comment on KAFKA-9878 at 5/23/20, 3:17 PM:
--
Thanks for
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114811#comment-17114811
]
Boyang Chen commented on KAFKA-9878:
Thanks for taking a look [~zhaohaidao], you are right about the
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9878:
---
Description:
Currently the EndTxn call from Producer will immediately return as the control
record
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111343#comment-17111343
]
Boyang Chen commented on KAFKA-9891:
Sorry I was oncall last week. Will take another look this week.
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Attachment: 166.tgz
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor
>
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
System test StreamsUpgradeTest.test_metadata_upgrade could fail due to:
"Never saw
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
System test StreamsUpgradeTest.test_metadata_upgrade could fail due to:
"Never saw
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9989:
--
Assignee: (was: Boyang Chen)
> StreamsUpgradeTest.test_metadata_upgrade could not
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Labels: newbie (was: )
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10010:
Summary: Should make state store registration idempotent (was: Should
close standby task for
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110638#comment-17110638
]
Boyang Chen commented on KAFKA-10010:
-
For more context, the
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110636#comment-17110636
]
Boyang Chen commented on KAFKA-10010:
-
Had offline discussion with the team, so far some action
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109610#comment-17109610
]
Boyang Chen commented on KAFKA-10010:
-
The gain for keeping the standby task open is not much when
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-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-:
---
Description:
We spotted a case in system test failure where the topic already exists but the
admin
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-:
---
Description:
We spotted a case in system test failure where the topic already exists but the
admin
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-:
---
Summary: Internal topic creation failure should be non-fatal and trigger
explicit rebalance (was:
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-:
--
Assignee: Boyang Chen
> Topic description should be triggered after each failed topic
[
https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108412#comment-17108412
]
Boyang Chen commented on KAFKA-9678:
[~m.sandeep] This ticket is already assigned, so feel free to
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107726#comment-17107726
]
Boyang Chen commented on KAFKA-9993:
Thanks [~vvcephei] An example is from the recent implementation
[
https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107672#comment-17107672
]
Boyang Chen commented on KAFKA-9676:
The current trunk has logic coverage for StandbyTaskCreator in
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-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107623#comment-17107623
]
Boyang Chen commented on KAFKA-9989:
Discussed with [~cadonna] and it seems to be caused by some
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9989:
--
Assignee: (was: Boyang Chen)
> StreamsUpgradeTest.test_metadata_upgrade could not
[
https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9994:
---
Description:
We have seen a case where the TaskMigrated exception gets thrown from
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
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106950#comment-17106950
]
Boyang Chen commented on KAFKA-9989:
I didn't find that in the log [~ableegoldman]
>
[
https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106857#comment-17106857
]
Boyang Chen commented on KAFKA-9984:
[~guozhang] Thanks!
> Should fail the subscription when pattern
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106853#comment-17106853
]
Boyang Chen commented on KAFKA-9989:
Looks like it is determined by the assignor: (the latest added
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
>
[
https://issues.apache.org/jira/browse/KAFKA-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106430#comment-17106430
]
Boyang Chen commented on KAFKA-8989:
Lost track, will close.
> Embedded broker could not be reached
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-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9878:
---
Summary: Block AddPartitionsToTxn call until the txn markers are committed
(was: Block EndTxn call
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-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102271#comment-17102271
]
Boyang Chen commented on KAFKA-9891:
I don't see the full log for 3 nodes you mentioned, where did
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100156#comment-17100156
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] Lol, no worry, thanks a lot for the insight
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100021#comment-17100021
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] on the other hand, if you are willing to work
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100020#comment-17100020
]
Boyang Chen commented on KAFKA-9891:
We had some offline discussion, and plan to revise the
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9453:
---
Description:
After 447, one of the big improvement is that we are no longer requiring single
writer
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9453:
---
Labels: needs-kip (was: )
> Make transaction.id optional in group mode EOS
>
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9453:
---
Parent: (was: KAFKA-8587)
Issue Type: Improvement (was: Sub-task)
> Make transaction.id
[
https://issues.apache.org/jira/browse/KAFKA-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9454:
---
Parent: (was: KAFKA-8587)
Issue Type: Improvement (was: Sub-task)
> Relax
[
https://issues.apache.org/jira/browse/KAFKA-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9454:
---
Component/s: streams
> Relax transaction.id security requirement
>
[
https://issues.apache.org/jira/browse/KAFKA-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9454:
---
Labels: needs-kip (was: )
> Relax transaction.id security requirement
>
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099547#comment-17099547
]
Boyang Chen commented on KAFKA-9453:
This could potentially simplify the setup for group mode EOS, as
[
https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9689:
---
Parent: (was: KAFKA-8587)
Issue Type: New Feature (was: Sub-task)
> Automatic broker
[
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
>
201 - 300 of 943 matches
Mail list logo
