Re: KafkaStreams Scala: Replace FunctionsCompatConversions

Hi John, You are right, and I really appreciate your help. I don't understand implicits well enough, as explicitly said. However - those functions are extremely useful: All the scala application code passes through them, and a guarded version of them makes applications guarded too. Put

[jira] [Resolved] (KAFKA-12760) Delete My Account

[ https://issues.apache.org/jira/browse/KAFKA-12760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12760. - Resolution: Invalid [~byusti] – we cannot delete your account either. You could try to

Re: Request to create a KIP

Done. On 5/6/21 9:18 AM, Parthasarathy, Mohan wrote: > Hi, > > I would like to create a proposal for enhancing the Streams API to support > additional aggregation functions. Requesting permission. My ID: mparthas99 > > Thanks > Mohan >

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #116

See Changes: -- [...truncated 476793 lines...] [2021-05-11T02:28:26.770Z] ControllerIntegrationTest > testTopicPartitionExpansionWithOfflineReplica() PASSED

[DISCUSS] KIP-737 Add canTrackSource to ReplicationPolicy

Hello everyone. I have a KIP that involves adding a public method to the ReplicationPolicy interface called canTrackSource. The intention behind creating this method is to implement an IdentityReplicationPolicy (aka LegacyReplicationPolicy) which is a MirrorMaker2 ReplicationPolicy that behaves

[jira] [Created] (KAFKA-12771) CheckStyle attempted upgrade (8.36.2 -->> 8.41.1) summons a pack of 'Indentation' errors

Dejan Stojadinović created KAFKA-12771: -- Summary: CheckStyle attempted upgrade (8.36.2 -->> 8.41.1) summons a pack of 'Indentation' errors Key: KAFKA-12771 URL:

[jira] [Created] (KAFKA-12770) Jenkins build: allow the CheckStyle version to be specified via parameter

Dejan Stojadinović created KAFKA-12770: -- Summary: Jenkins build: allow the CheckStyle version to be specified via parameter Key: KAFKA-12770 URL: https://issues.apache.org/jira/browse/KAFKA-12770

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #25

See

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

See

[jira] [Created] (KAFKA-12769) Backport of KAFKA-8562

Josep Prat created KAFKA-12769: -- Summary: Backport of KAFKA-8562 Key: KAFKA-12769 URL: https://issues.apache.org/jira/browse/KAFKA-12769 Project: Kafka Issue Type: Task Components:

[jira] [Created] (KAFKA-12768) Mirrormaker2 consumer config not using newly assigned client id

Vincent created KAFKA-12768: --- Summary: Mirrormaker2 consumer config not using newly assigned client id Key: KAFKA-12768 URL: https://issues.apache.org/jira/browse/KAFKA-12768 Project: Kafka Issue

Re: KafkaStreams Scala: Replace FunctionsCompatConversions

Hello Rama, There seems to be some fundamental confusion about how implicits work in Scala here. I'd like to re-iterate my strong advice not to go down this road. I've been there before, and it really does make it very difficult to maintain your codebase. If you just write the methods you have

Re: Backport of KAFKA-8562?

Hi Josep, It doesn't look to me like anyone was planning to do the backport, so if you're volunteering to do it, I think it would be appreciated. Thanks, -John On Mon, May 10, 2021, at 03:36, Josep Prat wrote: > Hi all, > > We are facing the problem described in >

[jira] [Created] (KAFKA-12767) Properly set Streams system test runtime classpath

John Roesler created KAFKA-12767: Summary: Properly set Streams system test runtime classpath Key: KAFKA-12767 URL: https://issues.apache.org/jira/browse/KAFKA-12767 Project: Kafka Issue

Re: [DISCUSS] KIP-618: Atomic commit of source connector records and offsets

Thanks for your thoughts, Randall. Responses below: RE exactly-once support in the REST API: > The worker has to do (or plan to do) something with the information about a connector's support for EOS, whether that's via an annotation or a method. Otherwise, what's the point of requiring the

[GitHub] [kafka-site] mimaison opened a new pull request #354: Updated downloads.html to include 2.7.1

mimaison opened a new pull request #354: URL: https://github.com/apache/kafka-site/pull/354 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this

Regarding Upgrade documentation for 2.8

Hello Team, Would like to upgrade my Kafka environment from 2.0.0 to 2.8.0, while going through documentation at link - https://kafka.apache.org/28/documentation.html#upgrade found no instructions has been shared for upgrade to 2.8.0, only changes are present, can see instructions till

Re: Permission to create KIP (Kafka Improvement Proposal)

Hi Matthew, I granted you permissions to create a KIP. Thank you for your interest in Apache Kafka. Best, Bruno On 10.05.21 12:10, Matthew de Detrich wrote: Wiki Id: mdedetrich-aiven

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #152

See Changes: [Mickael Maison] Bump version to 2.7.1 [Mickael Maison] MINOR: Update 2.7 branch version to 2.7.2-SNAPSHOT -- [...truncated 3.45 MB...]

Permission to create KIP (Kafka Improvement Proposal)

Wiki Id: mdedetrich-aiven -- Matthew de Detrich *Aiven Deutschland GmbH* Immanuelkirchstraße 26, 10405 Berlin Amtsgericht Charlottenburg, HRB 209739 B *m:* +491603708037 *w:* aiven.io *e:* matthew.dedetr...@aiven.io

[jira] [Created] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

Bruno Cadonna created KAFKA-12766: - Summary: Consider Disabling WAL-related Options in RocksDB Key: KAFKA-12766 URL: https://issues.apache.org/jira/browse/KAFKA-12766 Project: Kafka Issue

[jira] [Resolved] (KAFKA-8897) Increase Version of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8897. -- Resolution: Fixed > Increase Version of RocksDB > --- > >

Backport of KAFKA-8562?

Hi all, We are facing the problem described in https://issues.apache.org/jira/browse/KAFKA-8562 and we were wondering if the fix will be backported to 2.7 and 2.8 branches? If this is the case, I'm volunteering myself to do the backports. Thanks in advance, -- Josep Prat *Aiven Deutschland

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

See