[jira] [Reopened] (KAFKA-16305) Optimisation in SslTransportLayer:handshakeUnwrap stalls TLS handshake

2024-04-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reopened KAFKA-16305: reopen for backport to 3.7 > Optimisation in SslTransportLayer:handshakeUnwrap stalls

[jira] [Resolved] (KAFKA-16413) Add tests for FileLock

2024-04-03 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16413. Fix Version/s: 3.8.0 Resolution: Fixed > Add tests for FileL

[jira] [Resolved] (KAFKA-16435) Add test for KAFKA-16428

2024-04-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16435. Fix Version/s: 3.8.0 Resolution: Fixed > Add test for KAFKA-16

[jira] [Resolved] (KAFKA-16397) Use ByteBufferOutputStream to avoid array copy

2024-03-29 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16397. Fix Version/s: 3.8.0 Resolution: Fixed > Use ByteBufferOutputStream to avoid ar

[jira] [Created] (KAFKA-16447) Fix flaky ReplicaManagerTest

2024-03-29 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16447: -- Summary: Fix flaky ReplicaManagerTest Key: KAFKA-16447 URL: https://issues.apache.org/jira/browse/KAFKA-16447 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-16310) ListOffsets doesn't report the offset with maxTimestamp anymore

2024-03-27 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16310. Resolution: Fixed > ListOffsets doesn't report the offset with maxTimestamp anym

[jira] [Created] (KAFKA-16429) Enhance all configs which can trigger rolling of new segment

2024-03-27 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16429: -- Summary: Enhance all configs which can trigger rolling of new segment Key: KAFKA-16429 URL: https://issues.apache.org/jira/browse/KAFKA-16429 Project: Kafka

[jira] [Resolved] (KAFKA-16385) Segment is rolled before segment.ms or segment.bytes breached

2024-03-26 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16385. Fix Version/s: 3.8.0 Resolution: Fixed > Segment is rolled before segment

[jira] [Resolved] (KAFKA-16416) Use NetworkClientTest to replace RequestResponseTest to be the example of log4j output

2024-03-26 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16416. Fix Version/s: 3.8.0 Resolution: Fixed > Use NetworkClientTest to repl

Re: [ANNOUNCE] New committer: Christo Lolov

2024-03-26 Thread Chia-Ping Tsai
Congrats Christo! Chia-Ping

[jira] [Created] (KAFKA-16416) Use NetworkClientTest to replace RequestResponseTest to be the example of log4j output

2024-03-25 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16416: -- Summary: Use NetworkClientTest to replace RequestResponseTest to be the example of log4j output Key: KAFKA-16416 URL: https://issues.apache.org/jira/browse/KAFKA-16416

[jira] [Resolved] (KAFKA-16410) kafka-leader-election / LeaderElectionCommand doesn't set exit code on error

2024-03-24 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16410. Fix Version/s: 3.8.0 Resolution: Fixed > kafka-leader-elect

[jira] [Created] (KAFKA-16415) Make sure all subclass of CommandDefaultOptions can process "--help" and "–version"

2024-03-24 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16415: -- Summary: Make sure all subclass of CommandDefaultOptions can process "--help" and "–version" Key: KAFKA-16415 URL: https://issues.apache.org/jir

[jira] [Resolved] (KAFKA-16388) add production-ready test of 3.3 - 3.6 release to MetadataVersionTest.testFromVersionString

2024-03-23 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16388. Fix Version/s: 3.8.0 Resolution: Fixed > add production-ready test of 3.3 -

[jira] [Resolved] (KAFKA-16381) use volatile to guarantee KafkaMetric#config visibility across threads

2024-03-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16381. Fix Version/s: 3.8.0 Resolution: Fixed > use volatile to guarantee KafkaMet

Re: [VOTE] 3.6.2 RC1

2024-03-22 Thread Chia-Ping Tsai
hi Manikumar https://issues.apache.org/jira/browse/KAFKA-16341 has been resolved! thanks for your patience. best, Chia-Ping Chia-Ping Tsai 於 2024年3月22日 週五 上午10:32寫道: > > hi Manikumar > > > Pls let me know after merging the PR. I will generate RC2 later today. > > S

[jira] [Resolved] (KAFKA-16341) Fix un-compressed records

2024-03-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16341. Resolution: Fixed > Fix un-compressed reco

Re: [VOTE] 3.6.2 RC1

2024-03-21 Thread Chia-Ping Tsai
Pls let me know after merging the PR. I will generate RC2 later today. > > > Thank you, > > > > > > > On Thu, Mar 21, 2024 at 9:10 PM Chia-Ping Tsai wrote: > >>> Is this a regression from the 3.5.0 release? >> >> I believe the bug is exi

Re: [VOTE] 3.6.2 RC1

2024-03-21 Thread Chia-Ping Tsai
3.6.1 and 3.7.0 Manikumar 於 2024年3月21日 週四 下午11:12寫道: > Hi Chia-Ping, > > Thanks for letting me know. > > Is this a regression from the 3.5.0 release? Can we update the "Affects > Version/s" field on JIRA? > > Thanks, > > > On Thu, Mar 21

Re: [VOTE] 3.6.2 RC1

2024-03-21 Thread Chia-Ping Tsai
hi Manikumar, There is a bug fix which needs to be backport to 3.6 ( https://issues.apache.org/jira/browse/KAFKA-16341) It fixes the incorrect offset of max timestamp in non-compress path. The other paths are already fixed by https://issues.apache.org/jira/browse/KAFKA-16342. Personally, we

[jira] [Created] (KAFKA-16397) Use ByteBufferOutputStream to avoid array copy

2024-03-20 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16397: -- Summary: Use ByteBufferOutputStream to avoid array copy Key: KAFKA-16397 URL: https://issues.apache.org/jira/browse/KAFKA-16397 Project: Kafka Issue

Re: Quick review for my PR

2024-03-20 Thread Chia-Ping Tsai
Thanks for the contribution. I will take a look today. > Owen Leung 於 2024年3月21日 上午10:50 寫道: > > Hi there, > > Can I get a quick review for my PR ? Many thanks. > > https://github.com/apache/kafka/pull/15489 > > Best Regards > Owen

[jira] [Resolved] (KAFKA-12217) Apply the new features of Junit 5.8 to code base

2024-03-19 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12217. Resolution: Fixed > Apply the new features of Junit 5.8 to code b

[jira] [Resolved] (KAFKA-12187) replace assertTrue(obj instanceof X) by assertInstanceOf when we update to JUnit 5.8

2024-03-19 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12187. Fix Version/s: 3.8.0 Resolution: Fixed > replace assertTrue(obj instanceo

[jira] [Created] (KAFKA-16388) add production-ready test of 3.3 - 3.6 release to MetadataVersionTest.testFromVersionString

2024-03-19 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16388: -- Summary: add production-ready test of 3.3 - 3.6 release to MetadataVersionTest.testFromVersionString Key: KAFKA-16388 URL: https://issues.apache.org/jira/browse/KAFKA-16388

[jira] [Resolved] (KAFKA-16376) Fix flaky ReplicaManagerTest.testRemoteFetchExpiresPerSecMetric

2024-03-17 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16376. Resolution: Duplicate > Fix flaky ReplicaManagerTest.testRemoteFetchExpiresPerSecMet

[jira] [Resolved] (KAFKA-14971) Flaky Test org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest#testSyncTopicConfigs

2024-03-14 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-14971. Resolution: Duplicate KAFKA-15945 has filed PR so close this ticket > Flaky T

[jira] [Resolved] (KAFKA-15523) Flaky test org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest.testSyncTopicConfigs

2024-03-14 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-15523. Resolution: Duplicate KAFKA-15945 has filed PR so close this ticket > Flaky t

[jira] [Created] (KAFKA-16377) Fix flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

2024-03-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16377: -- Summary: Fix flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores Key: KAFKA-16377 URL: https://issues.apache.org/jira/browse

[jira] [Created] (KAFKA-16376) Fix flaky ReplicaManagerTest.testRemoteFetchExpiresPerSecMetric

2024-03-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16376: -- Summary: Fix flaky ReplicaManagerTest.testRemoteFetchExpiresPerSecMetric Key: KAFKA-16376 URL: https://issues.apache.org/jira/browse/KAFKA-16376 Project: Kafka

Re: [DISCUSS] Personal branches under apache/kafka

2024-03-14 Thread Chia-Ping Tsai
+1 to delete personal branches Also +1 to Matthias to disable push if the branch is nonexistent > committers for various > reasons, bugfix, tests. That is interesting. Can anyone share the details here? I’d like to know the bug/test which need to have a branch. Chia-Ping > Mickael Maison

[jira] [Resolved] (KAFKA-9690) MemoryLeak in JMX Reporter

2024-03-12 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-9690. --- Resolution: Duplicate close this due to https://issues.apache.org/jira/browse/KAFKA-9306

[jira] [Resolved] (KAFKA-9504) Memory leak in KafkaMetrics registered to MBean

2024-03-12 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-9504. --- Resolution: Duplicate close this due to https://issues.apache.org/jira/browse/KAFKA-9306

[jira] [Resolved] (KAFKA-16325) Add missing producer metrics to documentation

2024-03-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16325. Fix Version/s: 3.8.0 Resolution: Fixed > Add missing producer metr

[jira] [Resolved] (KAFKA-16202) Extra dot in error message in producer

2024-03-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16202. Fix Version/s: 3.8.0 Resolution: Fixed > Extra dot in error message in produ

[jira] [Resolved] (KAFKA-16265) Add durationFilter to ListTransactionsRequest

2024-03-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16265. Fix Version/s: 3.8.0 Resolution: Fixed > Add durationFil

[jira] [Created] (KAFKA-16348) Fix flaky TopicCommandIntegrationTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

2024-03-06 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16348: -- Summary: Fix flaky TopicCommandIntegrationTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress Key: KAFKA-16348 URL: https://issues.apache.org/jira/browse

[jira] [Resolved] (KAFKA-16322) Fix CVE-2023-50572 by updating jline from 3.22.0 to 3.25.1

2024-03-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16322. Fix Version/s: 3.8.0 Resolution: Fixed > Fix CVE-2023-50572 by updating jline f

[jira] [Resolved] (KAFKA-16252) Maligned Metrics formatting

2024-03-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16252. Resolution: Fixed > Maligned Metrics formatt

[jira] [Resolved] (KAFKA-16347) Bump ZooKeeper to 3.8.4

2024-03-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16347. Resolution: Fixed [~kevinztw] thanks for this contribution! > Bump ZooKeeper to 3.

[jira] [Created] (KAFKA-16346) Fix flay MetricsTest.testMetrics

2024-03-05 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16346: -- Summary: Fix flay MetricsTest.testMetrics Key: KAFKA-16346 URL: https://issues.apache.org/jira/browse/KAFKA-16346 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-16324) Move BrokerApiVersionsCommand to tools

2024-03-04 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16324: -- Summary: Move BrokerApiVersionsCommand to tools Key: KAFKA-16324 URL: https://issues.apache.org/jira/browse/KAFKA-16324 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-16322) Fix CVE-2023-50572 by updating jline from 3.22.0 to 3.25.1

2024-03-03 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16322: -- Summary: Fix CVE-2023-50572 by updating jline from 3.22.0 to 3.25.1 Key: KAFKA-16322 URL: https://issues.apache.org/jira/browse/KAFKA-16322 Project: Kafka

[jira] [Resolved] (KAFKA-12218) Upgrade Junit to 5.8+

2024-03-02 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12218. Resolution: Duplicate this was resolved by https://github.com/apache/kafka/pull/15404

Re: [ANNOUNCE] Apache Kafka 3.5.0

2023-06-15 Thread Chia-Ping Tsai
This is a great release. Mickael!!! > Chris Egerton 於 2023年6月15日 下午11:09 寫道: > > Mickael

Re: [ANNOUNCE] New committer: Divij Vaidya

2023-06-13 Thread Chia-Ping Tsai
Congratulations Divij :) > David Arthur 於 2023年6月14日 上午12:44 寫道: > > Congrats Divij! > > On Tue, Jun 13, 2023 at 12:34 PM Igor Soarez wrote: > >> Congratulations Divij! >> >> -- >> Igor >> > > > -- > -David

Re: [ANNOUNCE] Apache Kafka 3.4.1

2023-06-06 Thread Chia-Ping Tsai
data >> between systems or applications. >> >> ** Building real-time streaming applications that transform or react >> to the streams of data. >> >> Apache Kafka is in use at large and small companies worldwide, >> including Capital One, Goldman Sa

Re: [DISCUSS] Cluster Linking / Cross-Cluster Replication - Call for Interest & Co-Authors

2023-05-20 Thread Chia-Ping Tsai
Hi Greg I do love this feature/discussion :) I’d like to not only be a co-author/reviewer but also sponsor this feature by requesting our employees to be the contributors. Thanks! Chia-Ping > Luke Chen 於 2023年5月20日 下午6:47 寫道: > > Hi Greg, > > Thanks for starting this discussion. Yes, this

Re: [DISCUSS] Apache Kafka 3.4.1 release

2023-04-26 Thread Chia-Ping Tsai
+1 to Luke! > David Jacot 於 2023年4月26日 下午6:44 寫道: > > +1 Thanks, Luke! > >> Le mer. 26 avr. 2023 à 12:37, Luke Chen a écrit : >> >> Hi all, >> >> I'd like to volunteer as release manager for the Apache >> Kafka 3.4.1 release. >> If there are no objections, I'll start building a release

Re: Apache Kafka 3.6.0 release

2023-04-17 Thread Chia-Ping Tsai
+1 to Satish! Thanks! > Bruno Cadonna 於 2023年4月17日 下午5:09 寫道: > > Thanks Satish! > > +1 > > Best, > Bruno > >> On 16.04.23 20:02, Ismael Juma wrote: >> Thanks for volunteering Satish. +1. >> Ismael >>> On Sun, Apr 16, 2023 at 10:08 AM Satish Duggana >>> wrote: >>> Hi, >>> I would like to

Re: Failing tests in Kafka stream is under investigation now

2023-04-06 Thread Chia-Ping Tsai
hi Luke Thanks for your time and effort. It would be nice to see the green CI again :) — Chia-Ping > Luke Chen 於 2023年4月6日 下午6:13 寫道: > > Hi all, > > Just want to let you know, our current CI test results will contain > many(more than 600 in build 1738 >

[jira] [Created] (KAFKA-14874) Unable to create > 5000 topics for once when using Kraft

2023-03-31 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-14874: -- Summary: Unable to create > 5000 topics for once when using Kraft Key: KAFKA-14874 URL: https://issues.apache.org/jira/browse/KAFKA-14874 Project: Ka

[jira] [Resolved] (KAFKA-14853) the serializer/deserialize which extends ClusterResourceListener is not added to Metadata

2023-03-29 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-14853. Fix Version/s: 3.5.0 Resolution: Fixed > the serializer/deserialize which exte

[jira] [Created] (KAFKA-14853) the serializer/deserialize which extends ClusterResourceListener is never called

2023-03-27 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-14853: -- Summary: the serializer/deserialize which extends ClusterResourceListener is never called Key: KAFKA-14853 URL: https://issues.apache.org/jira/browse/KAFKA-14853

[jira] [Resolved] (KAFKA-14774) the removed listeners should not be reconfigurable

2023-03-27 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-14774. Fix Version/s: 3.5.0 Resolution: Fixed > the removed listeners sho

Re: Kafka Cluster WITHOUT Zookeeper

2023-03-27 Thread Chia-Ping Tsai
hiYou can use the keyword “kraft” to get the answer by google or chatgpt. For example:Introduction:KRaft - Apache Kafka Without ZooKeeperdeveloper.confluent.ioQuickStart:Apache Kafkakafka.apache.org—Chia-PingKafka Life 於 2023年3月27日 下午1:33 寫道:Hello  Kafka expertsIs there a way where we can have

[jira] [Resolved] (KAFKA-10244) An new java interface to replace 'kafka.common.MessageReader'

2023-03-25 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10244. Fix Version/s: 3.5.0 Resolution: Fixed > An new java interface to repl

Re: [DISCUSS] Apache Kafka 3.5.0 release

2023-03-23 Thread Chia-Ping Tsai
> If you have a KIP that is accepted, make sure it is listed in > https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+3.5.0 > and that it's status is accurate. Thanks for the reminder. Have added KIP-641 to the list. Thanks, Chia-Ping > Mickael Maison 於 2023年3月23日 下午11:51 寫道: > >

[jira] [Resolved] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

2023-03-21 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-6891. --- Fix Version/s: 3.5.0 Resolution: Fixed > send.buffer.bytes should be allowed to

Re: Failing ZkMigrationIntegrationTest

2023-03-17 Thread Chia-Ping Tsai
It seems to me KAFKA-14811 can fix the failure test :) > Ismael Juma 於 2023年3月17日 下午10:16 寫道: > > Thanks David. It may be worth temporarily disabling it unless we expect the > fix to be available today. > > Ismael > >> On Fri, Mar 17, 2023 at 6:58 AM David Arthur >> wrote: >> >> Hey folks,

[jira] [Created] (KAFKA-14811) The forwarding requests are discarded when network client is changed to/from zk/Kraft

2023-03-15 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-14811: -- Summary: The forwarding requests are discarded when network client is changed to/from zk/Kraft Key: KAFKA-14811 URL: https://issues.apache.org/jira/browse/KAFKA-14811

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

2023-03-15 Thread Chia-Ping Tsai
llow the `storage-api` example and have a module for > all extensible interfaces used by tools? > > Ismael > >> On Tue, Mar 14, 2023 at 9:23 AM Chia-Ping Tsai wrote: >> >> >> >>>> Chris Egerton 於 2023年3月15日 上午12:04 寫道: >>> >>

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

2023-03-14 Thread Chia-Ping Tsai
org.apache.kafka.tools`` — Chia-ping > > Ismael > > On Tue, Mar 14, 2023 at 9:23 AM Chia-Ping Tsai wrote: > >> >> >>> Chris Egerton 於 2023年3月15日 上午12:04 寫道: >>> >>> Hi Chia-Ping, >>> >>> Thanks for the KIP. I

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

2023-03-14 Thread Chia-Ping Tsai
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 o

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

2023-03-14 Thread Chia-Ping Tsai
ent packages. > > Cheers, > > Chris > > On Tue, Mar 7, 2023 at 6:30 AM Chia-Ping Tsai wrote: > >> hi Mickael >> >>> ?> configs) in the Compatibility, Deprecation, and Migration Plan, I >>> guess these can be removed now. >> >>

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

2023-03-13 Thread Chia-Ping Tsai
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: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158866569

Re: [ANNOUNCE] New Kafka PMC Member: Chris Egerton

2023-03-09 Thread Chia-Ping Tsai
Congratulations Chris! > Mickael Maison 於 2023年3月10日 上午2:21 寫道: > > Congratulations Chris! > >> On Thu, Mar 9, 2023 at 7:17 PM Bill Bejeck wrote: >> >> Congratulations Chris! >> >>> On Thu, Mar 9, 2023 at 1:12 PM Jun Rao wrote: >>> >>> Hi, Everyone, >>> >>> Chris Egerton has been a

Re: [ANNOUNCE] New Kafka PMC Member: David Arthur

2023-03-09 Thread Chia-Ping Tsai
Congratulations David! > Bill Bejeck 於 2023年3月10日 上午2:17 寫道: > > Congratulations David! > >> On Thu, Mar 9, 2023 at 1:12 PM Jun Rao wrote: >> >> Hi, Everyone, >> >> David Arthur has been a Kafka committer since 2013. He has been very >> instrumental to the community since becoming a

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

2023-03-07 Thread Chia-Ping Tsai (Jira)
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: [DISCUSS] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

2023-03-07 Thread Chia-Ping Tsai
nputStream 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 are s

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

2023-03-03 Thread Chia-Ping Tsai
Dear all, there are some changes for KIP-614 https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158866569 1) the interface RecordReader extends Configurable. 2) the input stream is removed from RecordReader#configure method 3) RecordReader#readRecords accept InputStream as

[jira] [Created] (KAFKA-14774) the removed listeners should not be reconfigurable

2023-03-02 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-14774: -- Summary: the removed listeners should not be reconfigurable Key: KAFKA-14774 URL: https://issues.apache.org/jira/browse/KAFKA-14774 Project: Kafka Issue

RE: [VOTE] KIP-907: Add Boolean Serde to public interface

2023-02-27 Thread Chia-Ping Tsai
+1 (binding)

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

2023-02-27 Thread Chia-Ping Tsai
e new interface though. > - Could we precise how errors will be handled? For instance, say that the > iterator could translate the input stream to a record. Would calling the > next method on the iterator throw an exception? > > Thanks, > David > > On Sat, Feb 25, 2023 at 10:43 PM

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

2023-02-25 Thread Chia-Ping Tsai
ned type of `readRecords(InputStream)` from single record to an iterator of records. Thus, the new interface not only extends Configurable but also take input stream only once. > > Cheers, > David > > Le mer. 22 févr. 2023 à 11:53, Chia-Ping Tsai a > écrit : > > > &

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

2023-02-24 Thread Chia-Ping Tsai
Dear all, All comments are addressed , and so please take look at this KIP. It needs vote and love :) thanks.

[jira] [Resolved] (KAFKA-14295) FetchMessageConversionsPerSec meter not recorded

2023-02-23 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-14295. Fix Version/s: 3.5.0 Resolution: Fixed > FetchMessageConversionsPerSec me

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

2023-02-22 Thread Chia-Ping Tsai
On 2023/02/22 10:01:29 Alexandre Dupriez wrote: > Hi Chia-Ping, > > Thanks for your answer. Apologies I should have been clearer in the > previous message. What I meant is, is there a plan to use the SPI more > broadly inside the Kafka codebase? no, there is no plan to reuse the SPI. > The

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

2023-02-22 Thread Chia-Ping Tsai
> A minor comment. The SPI is currently used exclusively for the > ConsoleProducer. However, it exposes high-level methods which hint at > it being a generic component. What is the actual scope of the SPI > inside the Kafka codebase? Is it planned to be re-used in other tools? > Or is this

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

2023-02-18 Thread Chia-Ping Tsai
On 2023/02/18 08:44:05 Tom Bentley wrote: > Hi Chia-Ping, > > To be honest the stateful version, setting an input stream once using the > `readFrom(InputStream)` method and then repeatedly asking for the next > record using a parameterless `readRecord()`, seems a bit more natural to me > than

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

2023-02-18 Thread Chia-Ping Tsai
Dear all, There is a change after I start this vote. The package is moved from "org.apache.kafka.common" to "org.apache.kafka.clients.tool". The purpose of the change is to enable tool-related interfaces to access code from "producer", "consumer", and "admin". Please verify the change before

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

2023-02-18 Thread Chia-Ping Tsai
Dear all, I noticed a issue after starting the vote :( The package "org.apache.kafka.common" disallows to import "org.apache.kafka.clients.producer.ProducerRecord". Hence, "org.apache.kafka.common.RecordReader" can't reference "org.apache.kafka.clients.producer.ProducerRecord" directly. It

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

2023-02-18 Thread Chia-Ping Tsai
Hi, I'd like to start the vote on KIP-614: An new java interface to replace 'kafka.common.MessageReader' KIP-614: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158866569 thread:

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

2023-02-18 Thread Chia-Ping Tsai
On 2023/02/17 06:47:18 Luke Chen wrote: > Hi Chia-Ping, > > Thanks for the KIP! > > Overall LGTM, just one minor comment: > Could we log warning messages to users when using deprecated MessageReader? Sure. I will address it when implementing the KIP.

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

2023-02-16 Thread Chia-Ping Tsai
hi Bentley I have updated the KIP to make RecordReader extend Configurable. PTAL

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

2023-02-16 Thread Chia-Ping Tsai
> 3. On the matter of configure(): While it doesn't add any functionality, it > would be more consistent with other plugins if this interface extended > Configurable, and the InputStream was then passed via some other method > (`readFrom(InputStream)` perhaps). If nothing else it would make it

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

2023-02-16 Thread Chia-Ping Tsai
On 2023/02/16 11:26:04 Federico Valeri wrote: > Hi Chia-Ping, thanks for updating the KIP. > > I would only add that we plan to remove the old trait in the next > major release. I think it's better to be explicit about this. sure. I have added this description to doc about deprecation.

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

2023-02-16 Thread Chia-Ping Tsai
Dear all, I have updated the KIP to address comments. PTAL https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158866569

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

2023-02-15 Thread Chia-Ping Tsai
> > guess in Kafka 4.0? > > Apart from that, the KIP looks good and considering how simple it is, > > you should be able to open a vote thread. > > > > Thanks, > > Mickael > > > > On Tue, Jul 7, 2020 at 5:55 PM Chia-Ping Tsai wrote: > > &g

[jira] [Created] (KAFKA-14717) KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely

2023-02-14 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-14717: -- Summary: KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely Key: KAFKA-14717 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Resolved] (KAFKA-9087) ReplicaAlterLogDirs stuck and restart fails with java.lang.IllegalStateException: Offset mismatch for the future replica

2023-01-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-9087. --- Fix Version/s: 3.5.0 Assignee: Chia-Ping Tsai Resolution: Fixed

[jira] [Resolved] (KAFKA-14544) The "is-future" should be removed from metrics tags after future log becomes current log

2022-12-25 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-14544. Resolution: Fixed > The "is-future" should be removed from metrics tags aft

[jira] [Created] (KAFKA-14544) The "is-future" should be removed from metrics tags after future log becomes current log

2022-12-21 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-14544: -- Summary: The "is-future" should be removed from metrics tags after future log becomes current log Key: KAFKA-14544 URL: https://issues.apache.org/jira/browse/K

[jira] [Created] (KAFKA-14019) removeMembersFromConsumerGroup can't delete all members when there is no members already

2022-06-24 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-14019: -- Summary: removeMembersFromConsumerGroup can't delete all members when there is no members already Key: KAFKA-14019 URL: https://issues.apache.org/jira/browse/KAFKA-14019

[jira] [Resolved] (KAFKA-13030) FindCoordinators batching causes slow poll when requesting older broker

2021-07-04 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-13030. Resolution: Duplicate close as duplicate (https://github.com/apache/kafka/pull/10963

[jira] [Created] (KAFKA-13030) FindCoordinators batching make slow poll when requesting older broker

2021-07-02 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-13030: -- Summary: FindCoordinators batching make slow poll when requesting older broker Key: KAFKA-13030 URL: https://issues.apache.org/jira/browse/KAFKA-13030 Project

[jira] [Resolved] (KAFKA-12662) add unit test for ProducerPerformance

2021-06-17 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12662. Fix Version/s: 3.0.0 Resolution: Fixed > add unit test for ProducerPerforma

[jira] [Resolved] (KAFKA-12661) ConfigEntry#equal does not compare other fields when value is NOT null

2021-05-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12661. Fix Version/s: 3.0.0 Resolution: Fixed > ConfigEntry#equal does not compare ot

[jira] [Resolved] (KAFKA-12702) Unhandled exception caught in InterBrokerSendThread

2021-04-25 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12702. Fix Version/s: 2.8.1 3.0.0 Resolution: Fixed > Unhand

[jira] [Resolved] (KAFKA-12684) The valid partition list is incorrectly replaced by the successfully elected partition list

2021-04-25 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12684. Resolution: Fixed > The valid partition list is incorrectly replaced by the successfu

<    1   2   3   4   5   6   >