st is
> very likely during leadership change unless producer uses idempotency? Is
> this a generic situation that no intent to provide data integration guarantee
> upon metadata change?
>
> From: Andrew Grant
> Sent: 20 November 2023 12:26
> T
Hey De Gao,
The controller is the one that always elects a new leader. When that happens
that metadata is changed on the controller and once committed it’s broadcast to
all brokers in the cluster. In KRaft this would be via a PartitonChange record
that each broker will fetch from the controller
[
https://issues.apache.org/jira/browse/KAFKA-15149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant resolved KAFKA-15149.
--
Resolution: Fixed
> Fix not sending UMR and LISR RPCs in dual-write mode when there are
Andrew Grant created KAFKA-15149:
Summary: Fix not sending RPCs in dual-write mode when there are
new partitions
Key: KAFKA-15149
URL: https://issues.apache.org/jira/browse/KAFKA-15149
Project: Kafka
t; >>>
> > >>>
> > >>> On Wed, May 31, 2023 at 6:46 PM Luke Chen wrote:
> > >>> >
> > >>> > Hi Greg and Andrew,
> > >>> >
> > >>> > Sorry, I don't know how to re-sent the invitation.
> &g
[
https://issues.apache.org/jira/browse/KAFKA-14791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant resolved KAFKA-14791.
--
Resolution: Fixed
> Create a builder class for PartitionRegistrat
Hi all,
Like Greg I also received an invitation to collaborate but was too slow to
accept the invite :( I'm also wondering if there's a way to resend the
invite? I'm andymg3 on GitHub.
Thanks,
Andrew
On Tue, May 30, 2023 at 12:12 PM Greg Harris
wrote:
> Hey all,
>
> I received an invitation to c
Andrew Grant created KAFKA-14829:
Summary: Consolidate reassignment logic in
PartitionReassignmentReplicas
Key: KAFKA-14829
URL: https://issues.apache.org/jira/browse/KAFKA-14829
Project: Kafka
Andrew Grant created KAFKA-14791:
Summary: Create a builder class for PartitionRegistration
Key: KAFKA-14791
URL: https://issues.apache.org/jira/browse/KAFKA-14791
Project: Kafka
Issue Type
Andrew Grant created KAFKA-14608:
Summary: Make sure reassignment does not cause under min ISR
Key: KAFKA-14608
URL: https://issues.apache.org/jira/browse/KAFKA-14608
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-14386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant resolved KAFKA-14386.
--
Resolution: Fixed
> Change ReplicaPlacer place method to return a class instead of list
Andrew Grant created KAFKA-14456:
Summary: Fix AdminUtils startIndex for rack aware partition
creations
Key: KAFKA-14456
URL: https://issues.apache.org/jira/browse/KAFKA-14456
Project: Kafka
Andrew Grant created KAFKA-14437:
Summary: Enhance StripedReplicaPlacer to account for existing
partition assignments
Key: KAFKA-14437
URL: https://issues.apache.org/jira/browse/KAFKA-14437
Project
Andrew Grant created KAFKA-14386:
Summary: Change ReplicaPlacer to return a class instead of list of
list of integers
Key: KAFKA-14386
URL: https://issues.apache.org/jira/browse/KAFKA-14386
Project
Hey David,
Thanks for the KIP. I had a few small questions.
“The ZK data migration will copy the existing ZK data into the KRaft
metadata log and establish the new KRaft active controller as the active
controller from a ZK perspective.”
How will the code get all the ZooKeeper config? Will it d
[
https://issues.apache.org/jira/browse/KAFKA-13892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant resolved KAFKA-13892.
--
Resolution: Fixed
> Dedupe RemoveAccessControlEntryRecord in deleteAcls of AclControlMana
Andrew Grant created KAFKA-13892:
Summary: Dedupe response objects in deleteAcls of
AclControlManager
Key: KAFKA-13892
URL: https://issues.apache.org/jira/browse/KAFKA-13892
Project: Kafka
Andrew Grant created KAFKA-13889:
Summary: Broker can't handle ACCESS_CONTROL_ENTRY_RECORD quickly
followed by REMOVE_ACCESS_CONTROL_ENTRY_RECORD for same ACL
Key: KAFKA-13889
URL: https://issues.apache.org
M PROCESSING
> PIPELINES by Sebastian Tallberg)
> showing Kafka's throughput hitting 3x the amount of msg/s if compared to
> Redis for a 1kB payload. I would like to understand what is in Kafka's
> architecture that allows it to be a lot faster than other message
> brokers/Redis in particular
>
> Thanks!
>
--
Andrew Grant
8054482621
Hi,
I’d look into Kafka streams https://kafka.apache.org/documentation/streams/.
You could use your connector to dump all records into a single topic and then
write a streams application that can use arbitrary logic to route records to
different downstream topics. A nice benefit, in my opinion,
20 matches
Mail list logo
