Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1749

See

[jira] [Created] (KAFKA-14896) TransactionsBounceTest causes a thread leak

Justine Olshan created KAFKA-14896: -- Summary: TransactionsBounceTest causes a thread leak Key: KAFKA-14896 URL: https://issues.apache.org/jira/browse/KAFKA-14896 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14895) Move AddPartitionsToTxnManager files to java

Justine Olshan created KAFKA-14895: -- Summary: Move AddPartitionsToTxnManager files to java Key: KAFKA-14895 URL: https://issues.apache.org/jira/browse/KAFKA-14895 Project: Kafka Issue Type:

Re: Fwd: [VOTE] KIP-914 Join Processor Semantics for Versioned Stores

Thanks for your comments and suggestions, Matthias, Lucas, and Guozhang! I was just in the process of responding when I saw Guozhang's message. I came up with a different approach to simplify my proposal with regards to the table aggregate processor, as part of mulling over comments from Matthias

Re: Fwd: [VOTE] KIP-914 Join Processor Semantics for Versioned Stores

Thanks Victoria. 1) I have no concerns about the filter operator's proposed semantics. 2) For aggregations, I have meta question in mind to discuss first, which is for those operators that generate a table, which is materialized as versioned, how we should emit out of order data if the operator

Re: [VOTE] KIP-875: First-class offsets support in Kafka Connect

Chris & Yash, 1. Since the global offsets topic does not have transactions on it already, I don't think adding transactions just for these reset operations would be an improvement. The transactional produce would not exclude other non-transactional producers, but hanging transactions on the

Re: Fwd: [VOTE] KIP-914 Join Processor Semantics for Versioned Stores

If we send old and new value as two messages, this should work I guess? Victory could confirm. -- But not if we send old/new as a single message in case the new-key does not change? -Matthias On 4/11/23 5:25 AM, Lucas Brutschy wrote: Hi, No concerns at all, just a clarifying question from

[jira] [Created] (KAFKA-14894) MetadataLoader must call finishSnapshot after loading a snapshot

Colin McCabe created KAFKA-14894: Summary: MetadataLoader must call finishSnapshot after loading a snapshot Key: KAFKA-14894 URL: https://issues.apache.org/jira/browse/KAFKA-14894 Project: Kafka

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #1748

See

[jira] [Created] (KAFKA-14893) Public API for reporting Yammer metrics

Mickael Maison created KAFKA-14893: -- Summary: Public API for reporting Yammer metrics Key: KAFKA-14893 URL: https://issues.apache.org/jira/browse/KAFKA-14893 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14892) Harmonize package names in storage module

Ismael Juma created KAFKA-14892: --- Summary: Harmonize package names in storage module Key: KAFKA-14892 URL: https://issues.apache.org/jira/browse/KAFKA-14892 Project: Kafka Issue Type:

Re: [VOTE] KIP-875: First-class offsets support in Kafka Connect

Hi all, A couple slight tweaks to the design have been proposed during implementation and I'd like to report them here to make sure that they're acceptable to all who previously voted for this KIP. I've updated the KIP to include these changes but will be happy to revert and/or amend if there are

Kafka's problems

Hi, I try to install kafka in a raspberry but the terminal of linux say me: Error: It hasn't find or load the principal class org.apache.zookeeper.server.quorum.QuorumPeer.Main I'd like that you help me, solving my problem. I wait your response as soon as you can.

[jira] [Resolved] (KAFKA-14783) Implement new STOPPED state for connectors

[ https://issues.apache.org/jira/browse/KAFKA-14783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14783. --- Fix Version/s: 3.5.0 Resolution: Done > Implement new STOPPED state for connectors >

[jira] [Created] (KAFKA-14891) Fix rack-aware range assignor to improve rack-awareness with co-partitioning

Rajini Sivaram created KAFKA-14891: -- Summary: Fix rack-aware range assignor to improve rack-awareness with co-partitioning Key: KAFKA-14891 URL: https://issues.apache.org/jira/browse/KAFKA-14891

Re: Fwd: [VOTE] KIP-914 Join Processor Semantics for Versioned Stores

Hi, No concerns at all, just a clarifying question from my side: for detecting out-of-order records, I need both new and old timestamp, I suppose I get it for the new record via timestamp extractor, can I not get it the same way from the old record that is passed down to the aggregation after

[jira] [Created] (KAFKA-14890) Kafka initiates shutdown due to connectivity problem with Zookeeper and FatalExitError from ChangeNotificationProcessorThread

Denis Razuvaev created KAFKA-14890: -- Summary: Kafka initiates shutdown due to connectivity problem with Zookeeper and FatalExitError from ChangeNotificationProcessorThread Key: KAFKA-14890 URL:

Re: [DISCUSS] KIP-910: Update Source offsets for Source Connectors without producing records

Hi Chris, Thanks for your detailed feedback! nits: I have taken care of them now. Thanks for pointing those out. non-nits: 6) It seems (based on both the KIP and discussion on KAFKA-3821) that the > only use case for being able to emit offsets without also emitting source > records that's been

[jira] [Resolved] (KAFKA-14731) Upgrade ZooKeeper to 3.6.4

[ https://issues.apache.org/jira/browse/KAFKA-14731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-14731. Resolution: Fixed > Upgrade ZooKeeper to 3.6.4 > -- > >

[jira] [Resolved] (KAFKA-14209) Optimize stream stream self join to use single state store

[ https://issues.apache.org/jira/browse/KAFKA-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vicky Papavasileiou resolved KAFKA-14209. - Resolution: Implemented > Optimize stream stream self join to use single state