Re: [VOTE] KIP-761: Add Total Blocked Time Metric to Streams

Thanks for the KIP. +1 (non-binding) Thank you. Luke On Wed, Sep 1, 2021 at 2:36 AM Guozhang Wang wrote: > Thanks for letting us know, Rohan. > > On Tue, Aug 31, 2021 at 1:08 AM Rohan Desai > wrote: > > > FYI I've updated the metric names in the KIP to the form > ".*-time-ns-total" > > and

Re: [DISCUSS] KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

Thanks for the KIP. Overall LGTM. Just one thought, if we "rename" the config directly as mentioned in the KIP, would that break existing applications? Should we deprecate the old one first, and make the old/new names co-exist for some period of time? Public Interfaces - Adding a new config

Re: [EXTERNAL] Re: Security vulnerabilities in kafka:2.13-2.6.0/2.7.0 docker image

Hi Ashish, CVE-2021-36159: It's a libfetch lib vulnerability. It's not Kafka's dependency lib. I guess it's the docker's base OS image. CVE-2019-17571: a log4j vulnerability. KAFKA-9366 is working on it. Thank you. Luke On Wed, Sep 1, 2021 at

[DISCUSS] KIP-767 Connect Latency Metrics

Hi all, I would like to start the discussion for KIP-767 involving adding latency metrics to Connect. The KIP can be found at https://cwiki.apache.org/confluence/display/KAFKA/KIP-767%3A+Connect+Latency+Metrics Thanks, Jordan

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

See Changes: -- [...truncated 491736 lines...] [2021-09-01T20:48:10.454Z] [2021-09-01T20:48:10.454Z] PlaintextConsumerTest > testConsumeMessagesWithCreateTime() PASSED

[jira] [Created] (KAFKA-13263) TimeoutException when calling initializeTransactions() in a healthy cluster, persisting until a broker was restarted

Donny Nadolny created KAFKA-13263: - Summary: TimeoutException when calling initializeTransactions() in a healthy cluster, persisting until a broker was restarted Key: KAFKA-13263 URL:

Re: [DISCUSS] KIP-771: KRaft broker should not expose controller metrics

Thank you Ron & Colin for the comments. I have updated the KIP with the suggested changes: https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=188743985=6=5 Regards, Ryan Dielhenn On 2021/08/31 22:41:21, "Colin McCabe" wrote: > Hi Ryan, > > Thanks for the KIP. > >

[jira] [Created] (KAFKA-13262) Mock Clients Now Have Final close() Methods

Gary Russell created KAFKA-13262: Summary: Mock Clients Now Have Final close() Methods Key: KAFKA-13262 URL: https://issues.apache.org/jira/browse/KAFKA-13262 Project: Kafka Issue Type: Bug

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

See Changes: -- [...truncated 490710 lines...] [2021-09-01T18:32:37.748Z] [2021-09-01T18:32:37.748Z] PlaintextConsumerTest > testConsumeMessagesWithCreateTime() PASSED

Jenkins build is back to stable : Kafka » Kafka Branch Builder » 3.0 #123

See

Re: [DISCUSS] KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

Currently the state store cache size default value is 10MB today, which arguably is rather small. So I'm thinking maybe for this config default to 512MB. Other than that, LGTM. On Sat, Aug 28, 2021 at 11:34 AM Sagar wrote: > Thanks Guozhang and Sophie. > > Yeah a small default value would

[jira] [Resolved] (KAFKA-13257) KafkaStreams Support For Latest RocksDB Version

[ https://issues.apache.org/jira/browse/KAFKA-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13257. --- Resolution: Not A Problem > KafkaStreams Support For Latest RocksDB Version >

[GitHub] [kafka-site] dajac merged pull request #369: Add public key for David Jacot

dajac merged pull request #369: URL: https://github.com/apache/kafka-site/pull/369 -- 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. To unsubscribe, e-mail:

[jira] [Resolved] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13175. --- Fix Version/s: 3.1.0 Resolution: Fixed > The topic is marked for deletion, create

[jira] [Resolved] (KAFKA-13234) Transaction system tests should check URPs between broker bounces

[ https://issues.apache.org/jira/browse/KAFKA-13234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13234. - Resolution: Fixed > Transaction system tests should check URPs between broker bounces >

Re: [VOTE] 3.0.0 RC1

Hi Konstantine, Some findings from running 3.0.0-RC1 with the librdkafka test suite: * Compaction seems to take slightly longer to kick in when segment sizes exceed their threshold. (Used to take less than 20 seconds, now takes 20..30 seconds.) * CreateTopic seems to take slightly longer to

[jira] [Created] (KAFKA-13261) KTable to KTable foreign key join does not produce output when using several partitions

Tomas Forsman created KAFKA-13261: - Summary: KTable to KTable foreign key join does not produce output when using several partitions Key: KAFKA-13261 URL: https://issues.apache.org/jira/browse/KAFKA-13261

RE: [EXTERNAL] Re: Security vulnerabilities in kafka:2.13-2.6.0/2.7.0 docker image

Hi Team I tried upgrading it to 2.13_2.8.0 but still have these vulnerabilities. [cid:image003.jpg@01D79F3D.5BA06A20] What is your suggestion on this? Thanks Ashish From: Jake Murphy Smith Sent: 01 September 2021 09:31 To: Ashish Patil Subject: RE: [EXTERNAL] Re: Security vulnerabilities in

[jira] [Created] (KAFKA-13260) FindCoordinator errorCounts does not handle v4

Mickael Maison created KAFKA-13260: -- Summary: FindCoordinator errorCounts does not handle v4 Key: KAFKA-13260 URL: https://issues.apache.org/jira/browse/KAFKA-13260 Project: Kafka Issue

[jira] [Created] (KAFKA-13259) DescribeProducers response does not include an error when it failed

Mickael Maison created KAFKA-13259: -- Summary: DescribeProducers response does not include an error when it failed Key: KAFKA-13259 URL: https://issues.apache.org/jira/browse/KAFKA-13259 Project:

[jira] [Created] (KAFKA-13258) AlterClientQuotas response does not include an error when it failed

Mickael Maison created KAFKA-13258: -- Summary: AlterClientQuotas response does not include an error when it failed Key: KAFKA-13258 URL: https://issues.apache.org/jira/browse/KAFKA-13258 Project:

[jira] [Created] (KAFKA-13257) KafkaStreams Support For Latest RocksDB Version

Alagukannan created KAFKA-13257: --- Summary: KafkaStreams Support For Latest RocksDB Version Key: KAFKA-13257 URL: https://issues.apache.org/jira/browse/KAFKA-13257 Project: Kafka Issue Type: