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

See

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

See

Re: [DISCUSS] KIP-793: Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

Hi Yash, I always use this issue as an example of a bug being caused by design rather than by implementation error, and once it's fixed I'll need to find something else to talk about :) So glad to see this get fixed! I'll chime in to support some of the earlier discussions that seem to have been

[jira] [Resolved] (KAFKA-14754) improve consumer under example package

[ https://issues.apache.org/jira/browse/KAFKA-14754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee resolved KAFKA-14754. Resolution: Fixed > improve consumer under example package >

[jira] [Resolved] (KAFKA-14753) improve producer under example package

[ https://issues.apache.org/jira/browse/KAFKA-14753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee resolved KAFKA-14753. Resolution: Fixed > improve producer under example package >

[jira] [Reopened] (KAFKA-14752) improve kafka examples under examples package

[ https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee reopened KAFKA-14752: > improve kafka examples under examples package > - > >

[jira] [Resolved] (KAFKA-14752) improve kafka examples under examples package

[ https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee resolved KAFKA-14752. Resolution: Fixed > improve kafka examples under examples package >

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

See

[jira] [Resolved] (KAFKA-14792) Race condition in LazyIndex.get()

[ https://issues.apache.org/jira/browse/KAFKA-14792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-14792. - Fix Version/s: 3.5.0 Resolution: Fixed > Race condition in LazyIndex.get() >

[DISCUSS] Migrating documentation to Markdown/Hugo

Hi all, I wanted to share on the mailing list a follow up from https://issues.apache.org/jira/browse/KAFKA-2967 to gather feedback from a wider audience: I put together a static-site generation with Hugo, and migrated most of the documentation under `docs/` to Markdown using Pandoc:

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

See

[jira] [Created] (KAFKA-14792) Race condition in LazyIndex.get()

Ismael Juma created KAFKA-14792: --- Summary: Race condition in LazyIndex.get() Key: KAFKA-14792 URL: https://issues.apache.org/jira/browse/KAFKA-14792 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-14351) Implement controller mutation quotas in KRaft

[ https://issues.apache.org/jira/browse/KAFKA-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino resolved KAFKA-14351. --- Fix Version/s: 3.5.0 Resolution: Fixed > Implement controller mutation quotas in

[jira] [Created] (KAFKA-14791) Create a builder class for PartitionRegistration

Andrew Grant created KAFKA-14791: Summary: Create a builder class for PartitionRegistration Key: KAFKA-14791 URL: https://issues.apache.org/jira/browse/KAFKA-14791 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-14640) Update AddPartitionsToTxn protocol to batch and handle verifyOnly requests

[ https://issues.apache.org/jira/browse/KAFKA-14640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan resolved KAFKA-14640. Resolution: Fixed > Update AddPartitionsToTxn protocol to batch and handle verifyOnly

[jira] [Created] (KAFKA-14790) Add more AddPartitionsToTxn tests in KafkaApis and Authorizer tests

Justine Olshan created KAFKA-14790: -- Summary: Add more AddPartitionsToTxn tests in KafkaApis and Authorizer tests Key: KAFKA-14790 URL: https://issues.apache.org/jira/browse/KAFKA-14790 Project:

[jira] [Created] (KAFKA-14789) Plugin ServiceLoader visibility from isolated plugins is inconsistent

Greg Harris created KAFKA-14789: --- Summary: Plugin ServiceLoader visibility from isolated plugins is inconsistent Key: KAFKA-14789 URL: https://issues.apache.org/jira/browse/KAFKA-14789 Project: Kafka

Re: [VOTE] KIP-903: Replicas with stale broker epoch should not be allowed to join the ISR

The KIP is accepted with 3 binding votes (David, Jun, Jason) and 1 non-binding vote (Alexandre). Thanks! On Tue, Feb 28, 2023 at 3:06 PM Jason Gustafson wrote: > Thanks Calvin, +1 from me. > > On Mon, Feb 27, 2023 at 9:41 AM Calvin Liu > wrote: > > > Hi Jason, > > Updated the fields

[DISCUSS] KIP-911: Add source tag to MirrorSourceConnector metrics

Hi, I created a KIP to tag the MirrorSourceConnector metrics with the source cluster alias. Currently they only have the target cluster alias. https://cwiki.apache.org/confluence/display/KAFKA/KIP-911%3A+Add+source+tag+to+MirrorSourceConnector+metrics Please take a look and let me know if you

Kafka General Question

Hello Kafka Team I am trying to some POC of the Messaging and it will working fine with the remote host and client . But I have question how I can send message/response from consumer to producer or server using topic . Please Guide me on this and share any doc if possible . Thank You Rohan Kar

Re: Problems with Kafka Connector Base classes

Hi Michael, Please feel free to file a PR to improve the docs, we welcome contributions! As far as a new status in the REST API goes, this would be a bit more involved and require a KIP ( https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals), but if you believe it would

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

See

[jira] [Created] (KAFKA-14788) Add TopicsToDeleteCount and ReplicasToDeleteCount to QuorumController

Chia-Ping Tsai created KAFKA-14788: -- Summary: Add TopicsToDeleteCount and ReplicasToDeleteCount to QuorumController Key: KAFKA-14788 URL: https://issues.apache.org/jira/browse/KAFKA-14788 Project:

Re: [VOTE] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

+1 (binding) Thanks for the KIP On Tue, Mar 7, 2023 at 11:31 AM Alexandre Dupriez wrote: > > +1 (non-binding). > > Thanks for driving this. > > Le mar. 7 mars 2023 à 08:47, Federico Valeri a écrit : > > > > + 1 (non binding) for the latest revision of this KIP (RecordReader). > > > > Thanks >

Re: [DISCUSS] KIP-908: Add description field to connector configuration

H Chris, Thanks for taking a look. 1. Yes updating the description can potentially trigger a rebalance. I don't expect users to frequently update the description so I thought this was acceptable. I've added a note to the KIP to mention it. 2. The tags model you described could be interesting

Re: [DISCUSS] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

hi Mickael > ?> configs) in the Compatibility, Deprecation, and Migration Plan, I > guess these can be removed now. Done! thanks for feedback > Mickael Maison 於 2023年3月7日 下午7:13 寫道： > > Hi Chia-Ping, > > The new API looks good. > I still see mentions to configure(InputStream inputStream, Map

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

See Changes: -- [...truncated 542269 lines...] [2023-03-07T11:24:59.558Z] > Task :storage:api:compileTestJava UP-TO-DATE [2023-03-07T11:24:59.558Z] > Task

Re: [DISCUSS] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

Hi Chia-Ping, The new API looks good. I still see mentions to configure(InputStream inputStream, Map configs) in the Compatibility, Deprecation, and Migration Plan, I guess these can be removed now. Thanks, Mickael On Fri, Mar 3, 2023 at 2:37 PM Chia-Ping Tsai wrote: > > Dear all, > > there

Re: [VOTE] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

+1 (non-binding). Thanks for driving this. Le mar. 7 mars 2023 à 08:47, Federico Valeri a écrit : > > + 1 (non binding) for the latest revision of this KIP (RecordReader). > > Thanks > Fede > > On Sat, Feb 25, 2023 at 7:04 AM Luke Chen wrote: > > > > +1 from me. > > > > Thank you > > Luke > >

[jira] [Resolved] (KAFKA-14770) Allow dynamic keystore update for brokers if string representation of DN matches even if canonical DNs don't match

[ https://issues.apache.org/jira/browse/KAFKA-14770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-14770. Reviewer: Manikumar Resolution: Fixed > Allow dynamic keystore update for brokers

Re: [VOTE] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

+ 1 (non binding) for the latest revision of this KIP (RecordReader). Thanks Fede On Sat, Feb 25, 2023 at 7:04 AM Luke Chen wrote: > > +1 from me. > > Thank you > Luke > > On Sat, Feb 25, 2023 at 8:39 AM Chia-Ping Tsai wrote: > > > Dear all, > > > > All comments are addressed , and so please