Re: [DISCUSS] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

Thanks for the reply, Matthias, I see what you mean. I suppose I was thinking that we would pass in the cached system time, which is also what we’re proposing to add to the ProcessorContext. If you think there’s something about the timestamp extractor in particular that would make people want

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Hi Yuriy, What a coincidence! I was just about to bump this thread myself. It would be really nice to get some more votes to push this over the line. Thanks for your patience! -John On Thu, Aug 13, 2020, at 23:45, Yuriy Badalyantc wrote: > Hi all > > Bumping this thread again > > On Mon,

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Hi all Bumping this thread again On Mon, Aug 10, 2020 at 10:07 AM William Reynolds < william.reyno...@instaclustr.com> wrote: > Looks good, > +1 (non binding) > > > *William Reynolds**Technical Operations Engineer* > > >

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Hi all, It seems like the main motivation for this proposal is satisfied if we just implement some recovery mechanism instead of crashing. If the mechanism is going to be pausing all the threads until the state is recovered, then it still seems like a big enough behavior change to warrant a

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #11

See

Re: [DISCUSS] KIP-639 Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

KIP updated with the comments of Bruno Cardona. Le 06/07/2020 à 22:36, Mohamed Chebbi a écrit : Thank Bruno for your review. Changes was added as you sugested. Le 06/07/2020 à 14:57, Bruno Cadonna a écrit : Hi Mohamed, Thank you for the KIP. Comments regarding the KIP wiki: 1. In section

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #10

See Changes: [github] KAFKA-10386; Fix flexible version support for `records` type (#9163) -- [...truncated 1.76 MB...]

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Harsha/Satish, Thanks for the great KIP. Below are the first set of questions/suggestions I had after making a pass on the KIP. 5001. Under the section "Follower fetch protocol in detail", the next-local-offset is the offset upto which the segments are copied to remote storage. Instead, would

[VOTE] KIP-657: Add Customized Kafka Streams Logo

Hello everyone, I would like to start a vote thread for KIP-657: https://cwiki.apache.org/confluence/display/KAFKA/KIP-657%3A+Add+Customized+Kafka+Streams+Logo This KIP is aiming to add a new logo for the Kafka Streams library. And we prepared two candidates with a cute otter. You could look up

Re: [DISCUSS] Apache Kafka 2.7.0 release

Thanks for volunteering Bill. :) Ismael On Thu, Aug 13, 2020 at 3:13 PM Bill Bejeck wrote: > Hi All, > > I'd like to volunteer to be the release manager for our next feature > release, 2.7. If there are no objections, I'll send out the release plan > soon. > > Thanks, > Bill Bejeck >

[DISCUSS] Apache Kafka 2.7.0 release

Hi All, I'd like to volunteer to be the release manager for our next feature release, 2.7. If there are no objections, I'll send out the release plan soon. Thanks, Bill Bejeck

[jira] [Created] (KAFKA-10400) Add a customized Kafka Streams logo

Boyang Chen created KAFKA-10400: --- Summary: Add a customized Kafka Streams logo Key: KAFKA-10400 URL: https://issues.apache.org/jira/browse/KAFKA-10400 Project: Kafka Issue Type: Improvement

RE: [EXTERNAL] Re: Request for access to create KIP

Accountid: koushikchitta Cheers, Koushik -Original Message- From: Boyang Chen Sent: Sunday, August 9, 2020 6:02 PM To: dev Subject: [EXTERNAL] Re: Request for access to create KIP Have you created the account already? What's your account id? On Sat, Aug 8, 2020 at 4:36 PM Koushik

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #11

See

[jira] [Created] (KAFKA-10399) Producer and consumer clients could log IP addresses for brokers to ease debugging

Lucas Bradstreet created KAFKA-10399: Summary: Producer and consumer clients could log IP addresses for brokers to ease debugging Key: KAFKA-10399 URL: https://issues.apache.org/jira/browse/KAFKA-10399

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #10

See Changes: [github] KAFKA-10386; Fix flexible version support for `records` type (#9163) -- [...truncated 3.20 MB...]

Re: Authentication Mechanisms for Kafka Connect Rest APIs

More context - I am a noob here and want some help so that I can contribute the auth bits. Should I create a JIRA or/and a KIP? If this is big enough for a KIP, please give me the permissions to create one (username - ifconfig) On Wed, Aug 12, 2020 at 1:24 PM mandeep gandhi wrote: > Hi all, >

[jira] [Resolved] (KAFKA-10386) Fix record serialization with flexible versions

[ https://issues.apache.org/jira/browse/KAFKA-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10386. - Resolution: Fixed > Fix record serialization with flexible versions >

[GitHub] [kafka-site] ableegoldman commented on pull request #294: MINOR: removing docs version header from 2.6 docs

ableegoldman commented on pull request #294: URL: https://github.com/apache/kafka-site/pull/294#issuecomment-673585020 Just tried in a different browser and I still only see the header on 2.5. The 2.4 formatting looks a little different, but no "You're viewing an older version..." header

[GitHub] [kafka-site] ableegoldman commented on pull request #294: MINOR: removing docs version header from 2.6 docs

ableegoldman commented on pull request #294: URL: https://github.com/apache/kafka-site/pull/294#issuecomment-673584334 Huh, I don't see the header on 2.4 (or earlier). Since this has been merged I now only see it on 2.5

[jira] [Created] (KAFKA-10398) Intra-broker disk move failed with onPartitionFenced()

Ming Liu created KAFKA-10398: Summary: Intra-broker disk move failed with onPartitionFenced() Key: KAFKA-10398 URL: https://issues.apache.org/jira/browse/KAFKA-10398 Project: Kafka Issue Type:

[jira] [Reopened] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-10134: - > High CPU issue during rebalance in Kafka consumer after upgrading to 2.5 >

[GitHub] [kafka-site] rhauch merged pull request #294: MINOR: removing docs version header from 2.6 docs

rhauch merged pull request #294: URL: https://github.com/apache/kafka-site/pull/294 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

[GitHub] [kafka-site] rhauch commented on pull request #294: MINOR: removing docs version header from 2.6 docs

rhauch commented on pull request #294: URL: https://github.com/apache/kafka-site/pull/294#issuecomment-673499292 @ableegoldman I see the header on 2.4 and earlier. IIUC, this is to *add* this header to the 2.5 docs and *remove* this header from all of the 2.6 docs (e.g.,

[jira] [Created] (KAFKA-10397) Do not Expose Statistics-based RocksDB Metrics If User Provides Statistics Object

Bruno Cadonna created KAFKA-10397: - Summary: Do not Expose Statistics-based RocksDB Metrics If User Provides Statistics Object Key: KAFKA-10397 URL: https://issues.apache.org/jira/browse/KAFKA-10397

Re: [VOTE] KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override

Hi David, Thank you for the suggestion. KIP-635 was referencing the --broker-list issue, but based on your suggestion, I pinged the PR https://github.com/apache/kafka/pull/8123. Since I got no response, I updated KIP-635 to deprecate --broker-list. Will update the PR related to KIP-635 to reflect

Build failed in Jenkins: Kafka » kafka-2.4-jdk8 #2

See Changes: [rajinisivaram] MINOR: Ensure same version of scala library is used for compile and at runtime (#9168) -- [...truncated 8.36 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #9

See Changes: [github] KAFKA-10391: Overwrite checkpoint in task corruption to remove corrupted partitions (#9170) -- [...truncated 6.43 MB...]

[jira] [Created] (KAFKA-10396) Overall memory of container keep on growing due to kafka stream / rocksdb and OOM killed once limit reached

Vagesh Mathapati created KAFKA-10396: Summary: Overall memory of container keep on growing due to kafka stream / rocksdb and OOM killed once limit reached Key: KAFKA-10396 URL:

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #10

See Changes: [github] KAFKA-10391: Overwrite checkpoint in task corruption to remove corrupted partitions (#9170) -- [...truncated 3.22 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #9

See Changes: [github] KAFKA-10391: Overwrite checkpoint in task corruption to remove corrupted partitions (#9170) -- [...truncated 3.19 MB...]