Re: Request for Permission

Hi Jeff. Your accounts are all set. Thank you. Luke On Wed, Mar 15, 2023 at 7:12 AM Jeff Kim wrote: > Hi, > > I would like to request permission to contribute to the Apache Kafka wiki. > For > > JIRA ID: jeffkbkim > Wiki ID: jeff.kim > > Thanks, > Jeff >

[jira] [Created] (KAFKA-14810) Refactor FileRawSansphotWriter to not reference ReplicateLog

José Armando García Sancio created KAFKA-14810: -- Summary: Refactor FileRawSansphotWriter to not reference ReplicateLog Key: KAFKA-14810 URL: https://issues.apache.org/jira/browse/KAFKA-14810

Release notes bug

Hello, Can the zk-upgrade bug KAFKA-14206 be removed from release notes for 3.4.0? Looks like it’s been superseded by KIP-902

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.4 #97

See Changes: -- [...truncated 523949 lines...] [2023-03-14T23:53:37.262Z] [2023-03-14T23:53:37.262Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 169 >

Request for Permission

Hi, I would like to request permission to contribute to the Apache Kafka wiki. For JIRA ID: jeffkbkim Wiki ID: jeff.kim Thanks, Jeff

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

See Changes: -- [...truncated 362079 lines...] [2023-03-14T22:45:35.521Z] > Task :group-coordinator:compileJava UP-TO-DATE [2023-03-14T22:45:35.521Z] > Task

Re: [DISCUSSION] MirrorMaker2 offset translation for compacted, filtered, and transactional source topics

Hey all! I realized that the information above is a bit in-the-weeds, and I think a re-framing of the situation might be necessary. Since the release of MM2, offsets translation has been limited to only performing translation ahead of the most recent offset sync. This limitation appears to have

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #161

See Changes: -- [...truncated 421497 lines...] [2023-03-14T19:54:23.170Z] [2023-03-14T19:54:23.170Z] org.apache.kafka.streams.integration.StoreQueryIntegrationTest >

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.4 #96

See Changes: -- [...truncated 524457 lines...] [2023-03-14T19:56:38.136Z] > Task :streams:javadoc [2023-03-14T19:56:38.136Z]

[jira] [Created] (KAFKA-14809) Fix logging conditional on WorkerSourceTask

Hector Geraldino created KAFKA-14809: Summary: Fix logging conditional on WorkerSourceTask Key: KAFKA-14809 URL: https://issues.apache.org/jira/browse/KAFKA-14809 Project: Kafka Issue

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

See Changes: -- [...truncated 451725 lines...] [2023-03-14T19:21:54.971Z] > Task :storage:api:testClasses UP-TO-DATE [2023-03-14T19:21:54.971Z] > Task

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

Hi juma > Ismael Juma 於 2023年3月15日 上午3:04 寫道： > > Hi Chia, > > Regarding `org.apache.kafka.clients.tool`, a few comments: > > 1. Why is it in `clients`? We don't generally consider tools to be a client. > 2. Why is it `tool`? We have a package `org.apache.kafka.tools`, so it's a > bit odd

[jira] [Resolved] (KAFKA-14794) Unable to deserialize base64 JSON strings

[ https://issues.apache.org/jira/browse/KAFKA-14794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio resolved KAFKA-14794. Fix Version/s: 3.5.0 Resolution: Fixed > Unable to

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

Hi Chia, Regarding `org.apache.kafka.clients.tool`, a few comments: 1. Why is it in `clients`? We don't generally consider tools to be a client. 2. Why is it `tool`? We have a package `org.apache.kafka.tools`, so it's a bit odd that this one uses singular instead of plural. 3. Also, should we

Re: Regarding Jira Account Creation

Hi Rohit, You can request the account creation in this url: https://selfserve.apache.org/jira-account.html On Tue, Mar 14, 2023 at 7:19 AM Rohit - wrote: > > Hi, I am Rohit, working as a Software Engineer at Confluent. Recently I > started working on

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

the vote for KIP-641 is completed +3 (binding) Luke Chen , Mickael Maison, Chris Egerton +2 (non-binding) Alexandre Dupriez , Federico Valeri thanks for all feedback and suggestions -- chia-ping On 2023/02/18 08:36:50 Chia-Ping Tsai wrote: > Hi, > > I'd like to start the vote on KIP-614: An

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

+1 (binding). Thanks! On Mon, Mar 13, 2023 at 11:39 AM Chia-Ping Tsai wrote: > ping for more voting :_ > > On 2023/02/18 08:36:50 Chia-Ping Tsai wrote: > > Hi, > > > > I'd like to start the vote on KIP-614: An new java interface to replace > 'kafka.common.MessageReader' > > > > KIP-614: >

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

Fair enough  On Tue, Mar 14, 2023 at 12:23 PM Chia-Ping Tsai wrote: > > > > Chris Egerton 於 2023年3月15日 上午12:04 寫道： > > > > Hi Chia-Ping, > > > > Thanks for the KIP. I find the interface definition really polished and > > intuitive! One small question--I noticed the change of the package to >

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

> Chris Egerton 於 2023年3月15日 上午12:04 寫道： > > Hi Chia-Ping, > > Thanks for the KIP. I find the interface definition really polished and > intuitive! One small question--I noticed the change of the package to > "org.apache.kafka.clients.tool". It doesn't look like there's any precedent > for

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

Hi Chia-Ping, Thanks for the KIP. I find the interface definition really polished and intuitive! One small question--I noticed the change of the package to "org.apache.kafka.clients.tool". It doesn't look like there's any precedent for using that package. We also use the "org.apache.kafka.common"

[jira] [Resolved] (KAFKA-10228) producer: NETWORK_EXCEPTION is thrown instead of a request timeout

[ https://issues.apache.org/jira/browse/KAFKA-10228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-10228. --- Fix Version/s: 3.5.0 Resolution: Duplicate > producer: NETWORK_EXCEPTION is thrown instead

Regarding Jira Account Creation

Hi, I am Rohit, working as a Software Engineer at Confluent. Recently I started working on https://issues.apache.org/jira/browse/KAFKA-14401. And raised a PR for the same here(https://github.com/apache/kafka/pull/13361). I wanted to have a JIRA account to assign the issue to myself and work on

[jira] [Resolved] (KAFKA-14803) topic deletion bug

[ https://issues.apache.org/jira/browse/KAFKA-14803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14803. --- Resolution: Duplicate > topic deletion bug > -- > > Key:

[jira] [Created] (KAFKA-14808) Partition becomes leaderless when new partition reassignment removes the adding replica

Shenglong Zhang created KAFKA-14808: --- Summary: Partition becomes leaderless when new partition reassignment removes the adding replica Key: KAFKA-14808 URL: https://issues.apache.org/jira/browse/KAFKA-14808

[jira] [Resolved] (KAFKA-14804) Connect docs fail to build with Gradle Swagger plugin 2.2.8

[ https://issues.apache.org/jira/browse/KAFKA-14804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-14804. Fix Version/s: 3.5.0 Resolution: Fixed > Connect docs fail to build with Gradle

[jira] [Created] (KAFKA-14807) MirrorMaker2 config source.consumer.auto.offset.reset=latest leading to the pause of replication of consumer groups

Zhaoli created KAFKA-14807: -- Summary: MirrorMaker2 config source.consumer.auto.offset.reset=latest leading to the pause of replication of consumer groups Key: KAFKA-14807 URL:

[jira] [Created] (KAFKA-14806) Add connection timeout in PlaintextSender used by SelectorTests

Alexandre Dupriez created KAFKA-14806: - Summary: Add connection timeout in PlaintextSender used by SelectorTests Key: KAFKA-14806 URL: https://issues.apache.org/jira/browse/KAFKA-14806 Project:

Re: Kafka Stream Metrics (3.3 / KAFKA-13945) and Documentation

Hi Neil, I think you are right that the type is wrong. Thank you for spotting the mistake! Since there is a MBean name column, I do not think we need to introduce a new section. We just need to change "type=stream-processor-node-metrics" to "type=stream-topic-metrics" for metrics