Skip to main content

Posts

Showing posts from March, 2023

RE: About CVE-2023-25194

We recently upgraded from 2.5.0 to 3.3.1. Our usage is pretty simple -- just basic pub/sub with the standard Java producer/consumer, nothing fancy. We just needed to make this one small change in our code: "The close(long, TimeUnit) method was removed from the producer, consumer and admin client. Please use close(Duration)." Otherwise, no problems, everything works for us the same as before. That said, it is a major version upgrade, so your mileage may vary! -Meg -----Original Message----- From: zjfplayer@hotmail.com < zjfplayer@hotmail.com > Sent: Tuesday, March 28, 2023 10:47 PM To: users < users@kafka.apache.org > Subject: About CVE-2023-25194 CAUTION: External Email : Be wary of clicking links or if this claims to be internal. Hi, Our kafka version is 2.x. I would like to ask everyone, is it risky to upgrade to version 3.4.0 in order to fix CVE-2023-25194? Because there are already customers using our products. ...

Re: About CVE-2023-25194

Hi, This is the commit to fix the CVE: https://github.com/apache/kafka/commit/ae22ec1a0ea005664439c3f45111aa34390ecaa1 2.x upgrades to 3.x includes a major version upgrade, so it'll have some compatibility issues. Please check the notable changes for v3.0 here: https://kafka.apache.org/documentation/#upgrade_300_notable Thank you. Luke On Wed, Mar 29, 2023 at 10:18 PM zjfplayer@hotmail.com < zjfplayer@hotmail.com > wrote: > Hi, > Our kafka version is 2.x. I would like to ask everyone, is it > risky to upgrade to version 3.4.0 in order to fix CVE-2023-25194? Because > there are already customers using our products. > Also, I would like to ask you how to fix CVE-2023-25194 on > version 2.x. I did not find the corresponding commit in the historical > commit of 3.4.0. Can someone help me find the corresponding commit record? > > > > zjfplayer@hotmail.com >

About CVE-2023-25194

Hi, Our kafka version is 2.x. I would like to ask everyone, is it risky to upgrade to version 3.4.0 in order to fix CVE-2023-25194? Because there are already customers using our products. Also, I would like to ask you how to fix CVE-2023-25194 on version 2.x. I did not find the corresponding commit in the historical commit of 3.4.0. Can someone help me find the corresponding commit record? zjfplayer@hotmail.com

Re: Kafka Cluster WITHOUT Zookeeper

David, hi, interesting thanks! Paul From: David Arthur <david.arthur@confluent.io.INVALID> Date: Wednesday, 29 March 2023 at 2:37 am To: Paul.Brebner@netapp.com.invalid <Paul.Brebner@netapp.com.invalid> Cc: users@kafka.apache.org < users@kafka.apache.org >, dev@kafka.apache.org < dev@kafka.apache.org >, mmcfarland@cavulus.com < mmcfarland@cavulus.com >, Israel Ekpo < israelekpo@gmail.com >, ranlupovich@gmail.com < ranlupovich@gmail.com >, scanterog@gmail.com < scanterog@gmail.com >, showuon@gmail.com < showuon@gmail.com >, sunilmchaudhari05@gmail.com < sunilmchaudhari05@gmail.com > Subject: Re: Kafka Cluster WITHOUT Zookeeper NetApp Security WARNING: This is an external email. Do not click links or open attachments unless you recognize the sender and know the content is safe. Paul, thanks for the articles. It's great to see someone digging into KRaft! It would be interesting to see your experiments...

Re: Kafka Cluster WITHOUT Zookeeper

Paul, thanks for the articles. It's great to see someone digging into KRaft! It would be interesting to see your experiments against a newer version of KRaft, such as 3.4.0. Also, we hope to improve on the maximum number of partitions with the addition of https://cwiki.apache.org/confluence/display/KAFKA/KIP-868+Metadata+Transactions which is likely to land in Kafka 3.5.0. Cheers, David On Mon, Mar 27, 2023 at 6:32 PM Brebner, Paul <Paul.Brebner@netapp.com.invalid> wrote: > I have a recent 3 part blog series on Kraft (expanded version of ApacheCon > 2022 talk): > > > > > https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-1-partitions-and-data-performance/ > > > https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-2-partitions-and-meta-data-performance/ > > > https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-3-maximum-parti...

Re: Kafka Cluster WITHOUT Zookeeper

This is really great information Paul . Thank you . On Tue, Mar 28, 2023 at 4:01 AM Brebner, Paul <Paul.Brebner@netapp.com.invalid> wrote: > I have a recent 3 part blog series on Kraft (expanded version of ApacheCon > 2022 talk): > > > > > https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-1-partitions-and-data-performance/ > > > https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-2-partitions-and-meta-data-performance/ > > > https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-3-maximum-partitions-and-conclusions/ > > > > Regards, Paul > > > > *From: *Chia-Ping Tsai < chia7712@gmail.com > > *Date: *Monday, 27 March 2023 at 5:37 pm > *To: * dev@kafka.apache.org < dev@kafka.apache.org > > *Cc: * users@kafka.apache.org < users@kafka.apache.org >, > mmcfarland@cavulus.com ...

Re: Kafka Cluster WITHOUT Zookeeper

I have a recent 3 part blog series on Kraft (expanded version of ApacheCon 2022 talk):   https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-1-partitions-and-data-performance/ https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-2-partitions-and-meta-data-performance/ https://www.instaclustr.com/blog/apache-kafka-kraft-abandons-the-zookeeper-part-3-maximum-partitions-and-conclusions/   Regards, Paul   From: Chia-Ping Tsai <chia7712@gmail.com> Date: Monday, 27 March 2023 at 5:37 pm To: dev@kafka.apache.org <dev@kafka.apache.org> Cc: users@kafka.apache.org <users@kafka.apache.org>, mmcfarland@cavulus.com <mmcfarland@cavulus.com>, Israel Ekpo <israelekpo@gmail.com>, ranlupovich@gmail.com <ranlupovich@gmail.com>, scanterog@gmail.com <scanterog@gmail.com>, showuon@gmail.com <showuon@gmail.com>, sunilmchaudhari05@gmail.com <sunilmchaudhari05@gma...

Re: 退出接受邮件

To unsubscribe from the users@kafka.apache.org mailing list, send a blank email to users-unsubscribe@kafka.apache.org from the email address you're subscribed with. So that you know, you will receive a confirmation email in response. Click on the confirmation link in that email to complete the unsubscribe process. Please check your spam or junk folder if you are still waiting for a confirmation email. I hope this helps. (I've translated to Chinese using a tool) (我已经用工具翻译成了中文) 要取消订阅 users@kafka.apache.org 邮件列表,请按照以下步骤操作: 从您订阅的电子邮件地址发送空电子邮件至 users-unsubscribe@kafka.apache.org 。 您将收到一封确认电子邮件作为回复。单击该电子邮件中的确认链接以完成取消订阅过程。 如果您没有收到确认电子邮件,请检查您的垃圾邮件或垃圾邮件文件夹。 希望这有所帮助。如果您有任何其他问题或疑虑,请随时回信。 On Mon, Mar 27, 2023 at 11:32 AM 韩宗庆 < 18811790647@163.com > wrote: > 你好,别人发给你的邮件,我也一直在收到,是否可以把我踢出用户组。

RE: Sudden imbalance between partitions

Hi Greg, Thank you very much for the quick and detailed response. Our clients are 2.5.0 so they do have the problematic version of the partitioner. From the metrics we have available, it's not 100% clear it is this issue, but there was a restart of some large components at the same time the problem started, so it is certainly plausible that it could have temporarily affected the node that went bad. We'll plan to upgrade the client and hope that solves it. Thanks! Meg -----Original Message----- From: Greg Harris <greg.harris@aiven.io.INVALID> Sent: Friday, March 24, 2023 5:13 PM To: users@kafka.apache.org Subject: Re: Sudden imbalance between partitions CAUTION: External Email : Be wary of clicking links or if this claims to be internal. Meg, What version are your clients, and what partitioner are you using for these records? If you're using the DefaultPartitioner from 2.4.0+, it has a known imbalance flaw that is described and addressed by ...

Re: Apache Kafka version - End of support

Many thanks Joseph for your response On Mon, Mar 27, 2023 at 4:50 PM Josep Prat <josep.prat@aiven.io.invalid> wrote: > Hello there, > > You can find the general policy here: > > https://cwiki.apache.org/confluence/display/KAFKA/Time+Based+Release+Plan#TimeBasedReleasePlan-WhatIsOurEOLPolicy > > Basically, the last 3 releases are covered and one can upgrade to the > latest version from the last previous 3. Bug fixes are ported to the last 3 > versions on a 'best effort basis'. Current latest release is 3.4.0. > Version 0.11 reached "end of support" (or EOL) a long time ago. > > Hope this helps, > > On Mon, Mar 27, 2023 at 12:44 PM Kafka Life < lifekafka999@gmail.com > > wrote: > > > > > > > > > > Hello Kafka experts > > > > > > where can i see the end of support for apache kafka versions? i would > > like > > > to know ab...

Re: Apache Kafka version - End of support

Hello there, You can find the general policy here: https://cwiki.apache.org/confluence/display/KAFKA/Time+Based+Release+Plan#TimeBasedReleasePlan-WhatIsOurEOLPolicy Basically, the last 3 releases are covered and one can upgrade to the latest version from the last previous 3. Bug fixes are ported to the last 3 versions on a 'best effort basis'. Current latest release is 3.4.0. Version 0.11 reached "end of support" (or EOL) a long time ago. Hope this helps, On Mon, Mar 27, 2023 at 12:44 PM Kafka Life < lifekafka999@gmail.com > wrote: > > > > > > Hello Kafka experts > > > > where can i see the end of support for apache kafka versions? i would > like > > to know about 0.11 Kafka version on when was this deprecated > > > -- [image: Aiven] < https://www.aiven.io > *Josep Prat* Open Source Engineering Director, *Aiven* josep.prat@aiven.io | +491715557497 aiven.io < h...

Why Kafka compacted topic doesnt delete tombstones?

Hi there, I have a kafka topic where my tombstone events don't get deleted and I don't know why. Maybe you can shed some light for me here? First about the usage of that topic: In our application, we regularly create new entities and create a UUID for those. I publish these entitites as JSON to kafka with the UUID being the key. If a user deletes such an entity, I send a kafka tombstone event for this UUID (i.e. NULL payload. I can verify them being correct NULL tombstones via kafkacat %S option reporting -1 length as synonym for NULL payload). In the QA environment of the project, multiple times a day new entities are created and deleted. It's not big amounts of data but over the 1.5 years this topic exists, its about 300.000 messages in total. It's not an issue in production where entities stay for a long time, but it starts slowing down our QA environment on starting up some services consuming the entire topic.. The topic is configured with: clean...

Re: Kafka Cluster WITHOUT Zookeeper

hi You can use the keyword "kraft" to get the answer by google or chatgpt. For example: Introduction: KRaft - Apache Kafka Without ZooKeeper developer.confluent.io QuickStart: Apache Kafka kafka.apache.org — Chia-Ping Kafka Life <lifekafka999@gmail.com> 於 2023年3月27日 下午1:33 寫道:  Hello  Kafka experts Is there a way where we can have Kafka Cluster be functional serving producers and consumers without having Zookeeper cluster manage the instance . Any particular version of kafka for this or how can we achieve this please

Broker Connection

I want to get more familiar with kafka and have trouble implementing it. Specifically getting error not being able to connect to broker and therefore not being able to use it. Would love osm advice. I am using windows and have configured everything correctly I believe. I can't think of why it's not working. Let me know where to ask or what to do. Thanks

Re: Sudden imbalance between partitions

Meg, What version are your clients, and what partitioner are you using for these records? If you're using the DefaultPartitioner from 2.4.0+, it has a known imbalance flaw that is described and addressed by this KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-794%3A+Strictly+Uniform+Sticky+Partitioner which was released in 3.3.0. In order to make sure you're using the patched partitioner, the clients jar should be on 3.3.0+ and your application should not set the `partitioner.class` configuration, to let the producer choose the behavior. In the short term, pausing, throttling, or restarting producers may help resolve the imbalance, since the poor balance is caused by the state of the producer buffers. Adding nodes to the cluster and spreading partitions thinner may also help increase the tolerance of each broker before it becomes unbalanced. However, this will not solve the problem on its own, and may make it temporarily worse while partitions ...

Sudden imbalance between partitions

Hi, We have a 22-node Kafka 3.3.1 cluster on K8s. All data is sent with null partitionId and null key from 20 Java producers, so it should be distributed evenly across partitions. All was good for days, but a couple hours ago, broker 21 started receiving about 2x the data of the other brokers for a few topics (but not all). These topics are all 1x replicated and the 96 partitions are distributed evenly across brokers (each broker has 4 or 5 partitions). This was detected in Grafana, but I can also see the offsets increasing much faster for the partitions owned by broker 21 in KafkaOffsetsShell. What could cause this? I didn't see anything unusual in the broker 21 logs or the controller logs. Looking back, I noticed that broker 11 also becomes a bit unbalanced each day at the time when we are processing the most data, but it is only 10-15% higher than the others. All other brokers are quite even, including broker 21 until today. Any ideas on what I can check? Unfortunately ...

Re: where is KafkaYammerMetrics.java moved to?

Zhou, It appears that this class was moved most recently in this PR: https://github.com/apache/kafka/pull/11970 Checking the build on trunk, the class does appear to be in the server-common JAR: $ jar -tf server-common/build/libs/kafka-server-common-3.5.0-SNAPSHOT.jar | grep Yammer org/apache/kafka/server/metrics/KafkaYammerMetrics.class KafkaYammerMetrics does not appear to be part of the documented API in the most recent release https://kafka.apache.org/34/javadoc/index.html or in prior releases. I believe this means that you are depending on internal classes of Kafka, and are subject to breakages like this when updating, even in patch releases. This is not recommended, and you should look into a long-term replacement for the KafkaYammerMetrics class. I hope this helps, Greg Harris On Wed, Mar 22, 2023 at 6:27 AM Rui < wirelesser@gmail.com > wrote: > Hi Kafka group: > recently I upgrade these libs to: > kafka-clients 3.4.0 > kafka...

where is KafkaYammerMetrics.java moved to?

Hi Kafka group: recently I upgrade these libs to: kafka-clients 3.4.0 kafka_2.13:3.4.0 spring-kafka-test:3.0.4 but I got a Class Not found issue:(stacktrace) Java.lang.NoClassDefFoundError: org/apache/kafka/server/metrics/KafkaYammerMetrics KafkaServer org.springframework.kafka.test.EmbeddedKafkaBroker.. It seems this file was removed from kafka_2.13 lib after checking the github, https://github.com/apache/kafka/blob/dd62ef2eda571576a222d757beabcd7690dd8c16/core/src/main/java/kafka/metrics/KafkaYammerMetrics.java So my question is which lib I should include as the dependency? thanks Zhou Rui

Re: can Kafka streams support ordering across 2 different topics when consuming from multiple source topics?

In general there is no ordering guarantee between topics. So it might depend a lot ofnthe details of your use case. For example, if you know that it will be always two event, you could buffer the first one in a state-store, and wait for the second one to arrive and decide in which order to forward both events downstream for actual processing. HTH, Matthias On 3/20/23 11:57 PM, Pushkar Deole wrote: > Hi All, > > We have a kafka streams application that consumes from 2 different topics > say topic A and topic B. The application uses data of telephone call on > those topics and each call has a call id which is used as key to send > events to those 2 topics. e.g. for a telephone call, the 1st event related > to that call is sent to A with call id however subsequent event for that > same call might go to topic B again with call id as key. > > *At times, we need to process those 2 events in an order, which is not > possible w...

Re: MirrorMaker 2.0 question

I got it to work by raising a kafka connect from which to launch the mm2. Silly question. El lun, 20 mar 2023 a las 23:09, Miguel Ángel Fernández Fernández (< miguelangelprogramacion@gmail.com >) escribió: > I have two clusters up on the same machine with docker-compose > > services: > zookeeper-lab: > image: "bitnami/zookeeper:3.8.1" > restart: always > environment: > ZOO_PORT_NUMBER: 2183 > ALLOW_ANONYMOUS_LOGIN: "yes" > ports: > - "2183:2183" > - "2886:2888" > - "3886:3888" > kafka-confluent: > image: "confluentinc/cp-kafka:6.2.0" > restart: always > environment: > - KAFKA_ZOOKEEPER_CONNECT=localhost:2183 > - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:29092 > network_mode: "host" > volumes: > - > "/home/m...

can Kafka streams support ordering across 2 different topics when consuming from multiple source topics?

Hi All, We have a kafka streams application that consumes from 2 different topics say topic A and topic B. The application uses data of telephone call on those topics and each call has a call id which is used as key to send events to those 2 topics. e.g. for a telephone call, the 1st event related to that call is sent to A with call id however subsequent event for that same call might go to topic B again with call id as key. *At times, we need to process those 2 events in an order, which is not possible with the current topology that we are using*. *Can someone suggest if this is possible to achieve with streams?* The topology is as below: Topic A has 6 partitions Topics B has 6 partitions Call id used as key on both topics Kafka streams application has 3 instances that consumes from both of the topics as source topics. Each streams application instance has 2 stream threads thus total 6 stream threads across 3 instances of streams application cater to 6 partition...

Re: MirrorMaker 2.0 question

I have two clusters up on the same machine with docker-compose services: zookeeper-lab: image: "bitnami/zookeeper:3.8.1" restart: always environment: ZOO_PORT_NUMBER: 2183 ALLOW_ANONYMOUS_LOGIN: "yes" ports: - "2183:2183" - "2886:2888" - "3886:3888" kafka-confluent: image: "confluentinc/cp-kafka:6.2.0" restart: always environment: - KAFKA_ZOOKEEPER_CONNECT=localhost:2183 - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:29092 network_mode: "host" volumes: - "/home/miguelangel/Documents/KafkaLab/mm2.properties:/var/lib/kafka/data/mm2.properties" and mm2 is running on one of them. Regarding the log, I don't see anything that seems suspicious to me. Not ERROR logs. [2023-03-20 22:03:14,290] WARN The configuration ' metrics.context.connect.group.id ' was supplied but isn't a known con...

Re: MirrorMaker 2.0 question

Mi Miguel, How many nodes are you running MM2 with? Just one? Separately, do you notice anything at ERROR level in the logs? Cheers, Chris On Mon, Mar 20, 2023 at 5:35 PM Miguel Ángel Fernández Fernández < miguelangelprogramacion@gmail.com > wrote: > Hello, > > I'm doing some tests with MirrorMaker 2 but I'm stuck. I have a couple of > kafka clusters, I think everything is set up correctly. However, when I run > > /bin/connect-mirror-maker /var/lib/kafka/data/mm2.properties > > the result I get is the creation of the topics > > mm2-configs.A.internal, > mm2-offsets.A.internal, > mm2-status.A.internal > > but not of the specific topics found in cluster A (topic1). > > The mm2.properties configuration is basically a copy of > > > https://github.com/apache/kafka/blob/trunk/config/connect-mirror-maker.properties > > modifying bootstrap servers > > A.boo...

MirrorMaker 2.0 question

Hello, I'm doing some tests with MirrorMaker 2 but I'm stuck. I have a couple of kafka clusters, I think everything is set up correctly. However, when I run /bin/connect-mirror-maker /var/lib/kafka/data/mm2.properties the result I get is the creation of the topics mm2-configs.A.internal, mm2-offsets.A.internal, mm2-status.A.internal but not of the specific topics found in cluster A (topic1). The mm2.properties configuration is basically a copy of https://github.com/apache/kafka/blob/trunk/config/connect-mirror-maker.properties modifying bootstrap servers A.bootstrap.servers = 127.0.0.1:29092 B.bootstrap.servers = 127.0.0.1:29093 Can anyone advise me with this problem? Is it possible that some configuration in mm2.properties is missing? Are there any real requirements regarding the configuration of the kafka clusters that may be overlooked? Thank you for your help, Miguel Ángel

Re: AW: Kafka Connect Startup Hook

unsubscribe On 20/03/2023, 10:30, "Jan Baudisch (extern)" < jan.baudisch.extern@bdess.com <mailto: jan.baudisch.extern@bdess.com >> wrote: CAUTION: This email originated from outside of the organization. Do not click links or open attachments unless you can confirm the sender and know the content is safe. Hello Jakub, thank you for you quick answer. We solved it by implementing a ConfigProvider, like described here: https://docs.confluent.io/kafka-connectors/self-managed/userguide.html#configprovider-interface < https://docs.confluent.io/kafka-connectors/self-managed/userguide.html#configprovider-interface > public class TracingConfigProvider implements ConfigProvider { @Override public void configure(Map<String, ?> map) { final JaegerTracer tracer = Configuration.fromEnv().getTracer(); GlobalTracer.registerIfAbsent(tracer); } @Override public ConfigData get(String s) { return null; } @Ov...

AW: Kafka Connect Startup Hook

Hello Jakub, thank you for you quick answer. We solved it by implementing a ConfigProvider, like described here: https://docs.confluent.io/kafka-connectors/self-managed/userguide.html#configprovider-interface public class TracingConfigProvider implements ConfigProvider { @Override public void configure(Map<String, ?> map) { final JaegerTracer tracer = Configuration.fromEnv().getTracer(); GlobalTracer.registerIfAbsent(tracer); } @Override public ConfigData get(String s) { return null; } @Override public ConfigData get(String s, Set<String> set) { return null; } @Override public void close(){} } And setting these Environment Variables in Kafka Connect - CONNECT_CONFIG_PROVIDERS=tracing - CONNECT_CONFIG_PROVIDERS_TRACING_CLASS=org.example.TracingConfigProvider Best regards, Jan Von: Jakub Scholz < jakub@scholz.cz > Datum: Montag, 20. M...

Re: Kafka Connect Startup Hook

In Strimzi, we use a Java agent to register the tracer ( https://github.com/strimzi/strimzi-kafka-operator/tree/main/tracing-agent/ if you wanna check the source code). Jakub On Mon, Mar 20, 2023 at 9:18 AM Jan Baudisch (extern) < jan.baudisch.extern@bdess.com > wrote: > Hello, > > can someone please give me a hint how to execute two lines of code upon > Kafka Connect Startup, like: > > final JaegerTracer tracer = Configuration.fromEnv().getTracer(); > GlobalTracer.register(tracer); > > I implemented using a custom (Fake-)Connector, but there is much overhead, > because you also need a Task, Config etc. > > Is there some simpler way, some kind of hook? > > Thanks in advance, > Jan > > >

Kafka Connect Startup Hook

Hello, can someone please give me a hint how to execute two lines of code upon Kafka Connect Startup, like: final JaegerTracer tracer = Configuration.fromEnv().getTracer(); GlobalTracer.register(tracer); I implemented using a custom (Fake-)Connector, but there is much overhead, because you also need a Task, Config etc. Is there some simpler way, some kind of hook? Thanks in advance, Jan

Kafka Connect Startup Hook

Hello, can someone please give me a hint how to execute two lines of code upon Kafka Connect Startup, like: final JaegerTracer tracer = Configuration.fromEnv().getTracer(); GlobalTracer.register(tracer); I implemented using a custom (Fake-)Connector, but there is much overhead, because you also need a Task, Config etc. Is there some simpler way, some kind of hook? Thanks in advance, Jan

Re: Questions about creating jira account

Hi Jimmy, You can create an account request via https://selfserve.apache.org/jira-account.html Thank you. Luke On Sat, Mar 18, 2023 at 12:03 AM zw <www.wangzhiwang@qq.com.invalid> wrote: > Hi, > It seems that JIRA access are disabled by default and I can't create an > account by myself. > > I would appreciate that if anyone could create an account for me. I am > interested and want to > contribute to the following ticket: > https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-10897 > > > Thank! > Regards, > > Jimmy Wang

回复:Subcribe

Hi, &nbsp; I&nbsp; like to subscribe to the developer community. &nbsp; Thank you, &nbsp; Xia ------------------&nbsp;原始邮件&nbsp;------------------ 发件人: "users" < devisri.amigos@gmail.com &gt;; 发送时间:&nbsp;2023年3月17日(星期五) 晚上6:31 收件人:&nbsp;"users"< users@kafka.apache.org &gt;; 主题:&nbsp;Subcribe Hi team, Would like to subscribe to the developer community. Thanks, Devisri..

Questions about creating jira account

Hi, It seems that JIRA access are disabled by default and I can't create an account by myself. I would appreciate that if anyone could create an account for me. I am interested and want to contribute to the following ticket: https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-10897 Thank! Regards, Jimmy Wang

Re: Exactly once kafka connect query

Hi Nitty, I understand your concerns about preserving intellectual property. Perhaps to avoid these altogether, instead of a call, you can provide a reproduction of your issues that is acceptable to share with the public? If I'm able to successfully diagnose the problem, I can share a summary on the mailing list, and if things are still unclear, I can join a call to discuss the publicly-visible example and what seems to be the issue. Cheers, Chris On Thu, Mar 16, 2023 at 5:54 AM NITTY BENNY < nittybenny@gmail.com > wrote: > Hi Xiaoxia, > > I am not able to see the attachments you shared with me. I don't understand > the problem you are talking about. > What do you want me to look? > > Thanks, > Nitty > > On Thu, Mar 16, 2023 at 1:54 AM 小侠 <747359285@qq.com.invalid> wrote: > > > Hi Nitty, > > I'm so sorry to forget the signature. > > Looking forward to your reply. > ...