Re: Confluent Schema Registry Compatibility config

Hi Mayuresh, since this is a Confluent-specific question and does not relate to Apache Kafka, I think it is better to ask your question in Confluent's community forum: https://forum.confluent.io/ There is even a Schema Registry category. Best, Bruno On 16.12.21 21:14, Mayuresh Gharat

Re: 并发问题请教

Hello, One blog post I can think of would be this: https://www.confluent.io/blog/kafka-fastest-messaging-system/ Here's one Chinese translation version that I found: https://www.sohu.com/a/417379110_355140 Hope it helps, Guozhang On Thu, Dec 16, 2021 at 9:27 PM 酒虫 wrote: > 你好， >

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

See Changes: -- [...truncated 213802 lines...] [2021-12-17T05:35:46.059Z] Execution optimizations have been disabled for task ':streams:processMessages' to ensure

????????????

?? kafka??

[jira] [Created] (KAFKA-13552) Unable to dynamically change broker log levels on KRaft

Ron Dagostino created KAFKA-13552: - Summary: Unable to dynamically change broker log levels on KRaft Key: KAFKA-13552 URL: https://issues.apache.org/jira/browse/KAFKA-13552 Project: Kafka

Jenkins build is unstable: Kafka » Kafka Branch Builder » 2.8 #93

See

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

See

Re: Confluent Schema Registry Compatibility config

Hi Folks, I was reading docs on Confluent Schema Registry about Compatibility : https://docs.confluent.io/platform/current/schema-registry/avro.html#compatibility-types I was confused with "BACKWARDS" vs "BACKWARDS_TRANSITIVE". If we have 3 schemas X, X-1, X-2 and configure a schema registry

Re: [VOTE] KIP-778 KRaft upgrades

Hi, David, Thanks for the KIP. It seems that we removed MinVersionLevel from ZK and FeatureLevelRecord in the latest change. Should we remove MinVersionLevel from ApiVersionsResponse too? Should we bump up the version in FeatureLevelRecord and ApiVersionsRequest? Jun On Thu, Dec 16, 2021 at

[jira] [Resolved] (KAFKA-13551) kafka-log4j-appender-2.1.1.jar Is cve-2021-44228 involved?

[ https://issues.apache.org/jira/browse/KAFKA-13551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-13551. - Resolution: Information Provided The impact is described in [https://kafka.apache.org/cve-list] >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 2.8 #92

See Changes: -- [...truncated 271437 lines...] [2021-12-16T17:39:14.500Z] [2021-12-16T17:39:14.500Z] SimpleAclAuthorizerTest > testAddAclsOnWildcardResource() PASSED

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #162

See

Re: [VOTE] KIP-778 KRaft upgrades

Thanks for the KIP, David! Great work. +1 (binding). Should the "./kafka-features.sh downgrade" command also have a --release flag, to match upgrade? Also, it seems like upgrade should have a --latest flag that upgrades everything to the latest installed version? best, Colin On Fri, Dec

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.1 #34

See Changes: -- [...truncated 500891 lines...] [2021-12-16T17:29:45.407Z] > Task :connect:json:testSrcJar [2021-12-16T17:29:45.407Z] > Task :metadata:compileTestJava

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

See

Re: [Proposal] It is hoped that Apache APISIX and Apache Kafka will carry out diversified community cooperation

Hi Yeliang Wang, Have you considered submitting a talk to Kafka Summit discussing how Apache APISIX uses Kafka? That might be interesting. I'm not sure what you mean by "fully integrating" the projects. Can you elaborate on what integration you see happening in the future? best, Colin On

Re: [VOTE] KIP-792: Add "generation" field into consumer protocol

Thanks for the explanation, Luke. That makes sense. best, Colin On Thu, Dec 9, 2021, at 13:31, Guozhang Wang wrote: > Thanks Luke, in that case I'm +1 on this KIP. > > On Thu, Dec 9, 2021 at 1:46 AM Luke Chen wrote: > >> Hi Guozhang, >> >> Thanks for your comment. >> >> > we need to make sure

[jira] [Resolved] (KAFKA-13492) IQ Parity: queries for key/value store range and scan

[ https://issues.apache.org/jira/browse/KAFKA-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-13492. -- Resolution: Fixed > IQ Parity: queries for key/value store range and scan >

[jira] [Resolved] (KAFKA-13488) Producer fails to recover if topic gets deleted (and gets auto-created)

[ https://issues.apache.org/jira/browse/KAFKA-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Agarwal resolved KAFKA-13488. - Reviewer: David Jacot Resolution: Fixed Fixed in

Re: [DISCUSS] Please review the 3.1.0 blog post

Hi David, A couple of minor nits: For KIP-783: "This field is set for any exception that originates from, or tied to, a specific task." should be "This field is set for any exception that originates from, or *is* tied to, a specific task." For KIP-690: "...so MM2 should have flexibility to let

Re: [VOTE] KIP-806: Add session and window query over KV-store in IQv2

Hi Partick, Thank you for the KIP! +1 (binding) Best, Bruno On 16.12.21 07:22, Luke Chen wrote: Hi Patrick, John, Thanks for your explanation and update. It looks better now. +1 (non-binding) from me. just one minor comment: 10. In the example section, we are still using the variable

Re: [DISCUSS] KIP-810: Allow producing records with null values in Kafka Console Producer

Hi Mickael, Thanks for the KIP! This will be a helpful feature for debugging, for sure! I have one question: Will we have some safe net for the collision of `key.separator` and the new introduced `null.marker`. That is, what if user set the same or overlapped `key.separator` and `null.marker`,

Re: [DISCUSS] KIP-591: Add Kafka Streams config to set default state store

Hi Guozhang, I've updated the KIP to use `enum`, instead of store implementation, and some content accordingly. Please let me know if there's other comments. Thank you. Luke On Sun, Dec 12, 2021 at 3:55 PM Luke Chen wrote: > Hi Guozhang, > > Thanks for your comments. > I agree that in the

[jira] [Created] (KAFKA-13551) kafka-log4j-appender-2.1.1.jar Is cve-2021-44228 involved?

xiansheng fu created KAFKA-13551: Summary: kafka-log4j-appender-2.1.1.jar Is cve-2021-44228 involved? Key: KAFKA-13551 URL: https://issues.apache.org/jira/browse/KAFKA-13551 Project: Kafka

Re: [VOTE] KIP-784: Add top-level error code field to DescribeLogDirsResponse

+1 (binding). Thanks for the KIP! On Mon, Dec 13, 2021 at 11:14 AM Mickael Maison wrote: > > Bumping this thread another time. > > This is a very minor change to make DescribeLogDirsResponse consistent > with the other APIs. > Let me know if you have any feedback. > > Thanks, > Mickael > > On

Re: [DISCUSS] Please review the 3.1.0 blog post

Hey folks, I have updated the blog post based on offline feedback that I have received. The changes were minor. Cheers, David On Wed, Dec 15, 2021 at 3:00 PM Igor Soarez wrote: > > Hi David, > > Apart from the obviously identified TODO items I coudln't find any issues. It > looks great! > >