[jira] [Updated] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer

[ https://issues.apache.org/jira/browse/KAFKA-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7371: --- Labels: beginner needs-kip newbie (was: needs-kip) > Finally deprec

[jira] [Commented] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854839#comment-17854839 ] Ayoub Omari commented on KAFKA-16925: - Thanks for these detailed clarifications ! I see now your

[jira] [Created] (KAFKA-16951) TransactionManager should rediscover coordinator on disconnection

Graham Campbell created KAFKA-16951: --- Summary: TransactionManager should rediscover coordinator on disconnection Key: KAFKA-16951 URL: https://issues.apache.org/jira/browse/KAFKA-16951 Project

[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback

[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854821#comment-17854821 ] Matthias J. Sax commented on KAFKA-16263: - [~brandboat] [~w4lt] – any updates on this ticket

[jira] [Commented] (KAFKA-16262) Add IQv2 to Kafka Streams documentation

[ https://issues.apache.org/jira/browse/KAFKA-16262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854832#comment-17854832 ] Suprem Vanam commented on KAFKA-16262: -- Hi [~mjsax], Not much of an update, still trying

[jira] [Commented] (KAFKA-16262) Add IQv2 to Kafka Streams documentation

[ https://issues.apache.org/jira/browse/KAFKA-16262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854822#comment-17854822 ] Matthias J. Sax commented on KAFKA-16262: - [~supremvanam] – Any updates on this ticket? >

[jira] [Assigned] (KAFKA-16950) Define Persister and Share Coordinator RPCs

[ https://issues.apache.org/jira/browse/KAFKA-16950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-16950: Assignee: Andrew Schofield > Define Persister and Share Coordinator R

[jira] [Updated] (KAFKA-16950) Define Persister and Share Coordinator RPCs

[ https://issues.apache.org/jira/browse/KAFKA-16950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal updated KAFKA-16950: -- Description: Add Persister interface with schemas for RPCs. The classes which are needed

[jira] [Created] (KAFKA-16950) Define Persister and Share Coordinator RPCs

Apoorv Mittal created KAFKA-16950: - Summary: Define Persister and Share Coordinator RPCs Key: KAFKA-16950 URL: https://issues.apache.org/jira/browse/KAFKA-16950 Project: Kafka Issue Type

[jira] [Created] (KAFKA-16949) System test test_dynamic_logging in connect_distributed_test is failing

Sagar Rao created KAFKA-16949: - Summary: System test test_dynamic_logging in connect_distributed_test is failing Key: KAFKA-16949 URL: https://issues.apache.org/jira/browse/KAFKA-16949 Project: Kafka

[jira] (KAFKA-16557) Fix OffsetFetchRequestState.toString()

[ https://issues.apache.org/jira/browse/KAFKA-16557 ] Fu Qiao deleted comment on KAFKA-16557: - was (Author: JIRAUSER304808): Hey [~kirktrue] : I am new to Kafka, and would like to start with some tasks. Would you mind if I pick this up?  Thanks

[jira] (KAFKA-16557) Fix OffsetFetchRequestState.toString()

[ https://issues.apache.org/jira/browse/KAFKA-16557 ] Fu Qiao deleted comment on KAFKA-16557: - was (Author: JIRAUSER304808): Created a PR for this if you don't mind: [https://github.com/apache/kafka/pull/15750] Thanks >

[jira] (KAFKA-16941) Flaky test - testDynamicBrokerConfigUpdateUsingKraft [1] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT – kafka.admin.ConfigCommandIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-16941 ] Lin Siyuan deleted comment on KAFKA-16941: was (Author: JIRAUSER303691): I'm a newbie and I will do my best to find the problem, it can take a long time, if others can find the problem

[jira] [Commented] (KAFKA-16781) Expose advertised.listeners in controller node

[ https://issues.apache.org/jira/browse/KAFKA-16781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854690#comment-17854690 ] Gantigmaa Selenge commented on KAFKA-16781: --- Thanks [~frankvicky] ,  I will reassign

[jira] [Assigned] (KAFKA-16781) Expose advertised.listeners in controller node

[ https://issues.apache.org/jira/browse/KAFKA-16781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gantigmaa Selenge reassigned KAFKA-16781: - Assignee: Gantigmaa Selenge (was: TengYao Chi) > Expose advertised.listen

[jira] [Resolved] (KAFKA-16643) Add ModifierOrder checkstyle rule

[ https://issues.apache.org/jira/browse/KAFKA-16643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16643. Fix Version/s: 3.9.0 Resolution: Fixed > Add ModifierOrder checkstyle r

[jira] [Resolved] (KAFKA-16557) Fix OffsetFetchRequestState.toString()

[ https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16557. Resolution: Fixed > Fix OffsetFetchRequestState.toStr

[jira] [Resolved] (KAFKA-16901) add unit tests for ConsumerRecords#records(String)

[ https://issues.apache.org/jira/browse/KAFKA-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16901. Fix Version/s: 3.9.0 Resolution: Fixed > add unit tests for ConsumerReco

[jira] [Created] (KAFKA-16948) Reset tier lag metrics on becoming follower

Kamal Chandraprakash created KAFKA-16948: Summary: Reset tier lag metrics on becoming follower Key: KAFKA-16948 URL: https://issues.apache.org/jira/browse/KAFKA-16948 Project: Kafka

[jira] [Commented] (KAFKA-12480) Reuse bootstrap servers in clients when last alive broker in cluster metadata is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-12480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854611#comment-17854611 ] Ivan Yurchenko commented on KAFKA-12480: With [KIP-899|https://cwiki.apache.org/confluence

[jira] [Commented] (KAFKA-13467) Clients never refresh cached bootstrap IPs

[ https://issues.apache.org/jira/browse/KAFKA-13467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854612#comment-17854612 ] Ivan Yurchenko commented on KAFKA-13467: With [KIP-899|https://cwiki.apache.org/confluence

[jira] [Commented] (KAFKA-16781) Expose advertised.listeners in controller node

[ https://issues.apache.org/jira/browse/KAFKA-16781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854610#comment-17854610 ] TengYao Chi commented on KAFKA-16781: - Hi [~tinaselenge] feel free to take this if you wish

[jira] [Assigned] (KAFKA-14507) Add ConsumerGroupPrepareAssignment API

[ https://issues.apache.org/jira/browse/KAFKA-14507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dujian0068 reassigned KAFKA-14507: -- Assignee: dujian0068 > Add ConsumerGroupPrepareAssignment

[jira] [Assigned] (KAFKA-14705) Remove deprecated options and redirections

[ https://issues.apache.org/jira/browse/KAFKA-14705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dujian0068 reassigned KAFKA-14705: -- Assignee: dujian0068 > Remove deprecated options and redirecti

[jira] [Commented] (KAFKA-16941) Flaky test - testDynamicBrokerConfigUpdateUsingKraft [1] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT – kafka.admin.ConfigCommandIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-16941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854604#comment-17854604 ] Lin Siyuan commented on KAFKA-16941: I'm a newbie and I will do my best to find the problem, it can

[jira] [Commented] (KAFKA-16913) Support external schemas in JSONConverter

[ https://issues.apache.org/jira/browse/KAFKA-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854601#comment-17854601 ] Ganesh Sadanala commented on KAFKA-16913: - is there any documentation to be updated

[jira] [Commented] (KAFKA-16913) Support external schemas in JSONConverter

[ https://issues.apache.org/jira/browse/KAFKA-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854600#comment-17854600 ] Ganesh Sadanala commented on KAFKA-16913: - PR is ready to review > Support external sche

[jira] [Commented] (KAFKA-16946) Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port

[ https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854595#comment-17854595 ] Luke Chen commented on KAFKA-16946: --- [~frankvicky] , this is a blocker for v3.8.0. Hope we can fix

[jira] [Updated] (KAFKA-16946) Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port

[ https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-16946: -- Fix Version/s: 3.8.0 > Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:p

[jira] [Resolved] (KAFKA-16938) non-dynamic props gets corrupted due to circular reference between DynamicBrokerConfig and DynamicConfig

[ https://issues.apache.org/jira/browse/KAFKA-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16938. Resolution: Fixed > non-dynamic props gets corrupted due to circular reference betw

[jira] [Commented] (KAFKA-16944) Range assignor doesn't co-partition with stickiness

[ https://issues.apache.org/jira/browse/KAFKA-16944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854593#comment-17854593 ] dujian0068 commented on KAFKA-16944: Hello, does this problem need to be fixed quickly? If not, can

[jira] [Commented] (KAFKA-16946) Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port

[ https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854591#comment-17854591 ] Luke Chen commented on KAFKA-16946: --- Go ahead to fix it, [~frankvicky] ! > Utils.getHost/getP

[jira] [Assigned] (KAFKA-16946) Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port

[ https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-16946: - Assignee: TengYao Chi > Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:p

[jira] [Updated] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads.

[ https://issues.apache.org/jira/browse/KAFKA-13560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-13560: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Load indexes and data in as

[jira] [Updated] (KAFKA-15300) Include remotelog size in complete log size and also add local log size and remote log size separately in kafka-log-dirs tool.

[ https://issues.apache.org/jira/browse/KAFKA-15300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15300: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Include remotelog s

[jira] [Updated] (KAFKA-15480) Add RemoteStorageInterruptedException

[ https://issues.apache.org/jira/browse/KAFKA-15480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15480: --- Fix Version/s: 3.9.0 (was: 3.8.0) >

[jira] [Updated] (KAFKA-15214) Add metrics for OffsetOutOfRangeException when tiered storage is enabled

[ https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15214: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Add metr

[jira] [Updated] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest

[ https://issues.apache.org/jira/browse/KAFKA-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15529: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Flaky t

[jira] [Updated] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager

[ https://issues.apache.org/jira/browse/KAFKA-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15038: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Use topic id/name mapping f

[jira] [Commented] (KAFKA-16946) Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port

[ https://issues.apache.org/jira/browse/KAFKA-16946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854582#comment-17854582 ] TengYao Chi commented on KAFKA-16946: - Hi [~showuon] , if the issue finder is not willing to do, I

[jira] [Updated] (KAFKA-9578) Kafka Tiered Storage - System Tests

[ https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-9578: -- Fix Version/s: 3.9.0 (was: 3.8.0) > Kafka Tiered Storage - Sys

[jira] [Updated] (KAFKA-15132) Implement disable & re-enablement for Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-15132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15132: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Implement disable &

[jira] [Updated] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15376: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Explore options of removing d

[jira] [Updated] (KAFKA-15864) Add more tests asserting the log-start-offset, local-log-start-offset, and HW/LSO/LEO in rolling over segments with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15864: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Add more tests asserting the

[jira] [Updated] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures.

[ https://issues.apache.org/jira/browse/KAFKA-15094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15094: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Add RemoteIndexCache metr

[jira] [Updated] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets.

[ https://issues.apache.org/jira/browse/KAFKA-14915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-14915: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Option to consume multi

[jira] [Updated] (KAFKA-15195) Regenerate segment-aligned producer snapshots when upgrading to a Kafka version supporting Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-15195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15195: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Regenerate segment-alig

[jira] [Updated] (KAFKA-15301) [Tiered Storage] Historically compacted topics send request to remote for active segment during consume

[ https://issues.apache.org/jira/browse/KAFKA-15301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15301: --- Fix Version/s: 3.9.0 (was: 3.8.0) > [Tiered Storage] Historica

[jira] [Updated] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15341: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Enabling TS for a topic dur

[jira] [Updated] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM.

[ https://issues.apache.org/jira/browse/KAFKA-13355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-13355: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Shutdown broker eventually w

[jira] [Updated] (KAFKA-15969) Align RemoteStorageThreadPool metrics name with KIP-405

[ https://issues.apache.org/jira/browse/KAFKA-15969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15969: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Align RemoteStorageThreadP

[jira] [Updated] (KAFKA-15331) Handle remote log enabled topic deletion when leader is not available

[ https://issues.apache.org/jira/browse/KAFKA-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15331: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Handle remote log enabled to

[jira] [Updated] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-15388: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Handle topics that were hav

[jira] [Commented] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854579#comment-17854579 ] Satish Duggana commented on KAFKA-14877: InMemoryLeaderEpochCheckpoint seems to be deleted

[jira] [Resolved] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana resolved KAFKA-14877. Resolution: Invalid > refactor InMemoryLeaderEpochCheckpo

[jira] [Resolved] (KAFKA-16935) Automatically wait for cluster startup in embedded Connect integration tests

[ https://issues.apache.org/jira/browse/KAFKA-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-16935. --- Resolution: Fixed > Automatically wait for cluster startup in embedded Connect integrat

[jira] [Reopened] (KAFKA-16935) Automatically wait for cluster startup in embedded Connect integration tests

[ https://issues.apache.org/jira/browse/KAFKA-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-16935: --- > Automatically wait for cluster startup in embedded Connect integration te

[jira] [Updated] (KAFKA-16935) Automatically wait for cluster startup in embedded Connect integration tests

[ https://issues.apache.org/jira/browse/KAFKA-16935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-16935: -- Fix Version/s: 3.8.0 > Automatically wait for cluster startup in embedded Connect integrat

[jira] [Updated] (KAFKA-16947) Kafka Tiered Storage V2

[ https://issues.apache.org/jira/browse/KAFKA-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-16947: --- Fix Version/s: 3.9.0 (was: 3.8.0) > Kafka Tiered Storage

[jira] [Resolved] (KAFKA-13561) Consider deprecating `StreamsBuilder#build(props)` function

[ https://issues.apache.org/jira/browse/KAFKA-13561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13561. - Resolution: Duplicate > Consider deprecating `StreamsBuilder#build(props)` funct

[jira] [Updated] (KAFKA-16947) Kafka Tiered Storage V2

[ https://issues.apache.org/jira/browse/KAFKA-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-16947: --- Affects Version/s: (was: 3.6.0) > Kafka Tiered Storage

[jira] [Created] (KAFKA-16947) Kafka Tiered Storage V2

Satish Duggana created KAFKA-16947: -- Summary: Kafka Tiered Storage V2 Key: KAFKA-16947 URL: https://issues.apache.org/jira/browse/KAFKA-16947 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-16945) Cleanup StreamsBuilder and TopologyConfig

[ https://issues.apache.org/jira/browse/KAFKA-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854578#comment-17854578 ] Matthias J. Sax commented on KAFKA-16945: - I did not look... :P Found https://issues.apache.org

[jira] [Resolved] (KAFKA-16890) Failing to build aux state on broker failover

[ https://issues.apache.org/jira/browse/KAFKA-16890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana resolved KAFKA-16890. Resolution: Fixed > Failing to build aux state on broker failo

[jira] [Commented] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854577#comment-17854577 ] Matthias J. Sax commented on KAFKA-16925: - {quote}My understanding is that the processor here

[jira] [Created] (KAFKA-16946) Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port

Luke Chen created KAFKA-16946: - Summary: Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port Key: KAFKA-16946 URL: https://issues.apache.org/jira/browse/KAFKA-16946 Project: Kafka

[jira] [Commented] (KAFKA-16939) Revisit ConfigCommandIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-16939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854573#comment-17854573 ] 黃竣陽 commented on KAFKA-16939: - I will fix it ASAP. > Revisit ConfigCommandIntegrationT

[jira] [Commented] (KAFKA-16945) Cleanup StreamsBuilder and TopologyConfig

[ https://issues.apache.org/jira/browse/KAFKA-16945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854565#comment-17854565 ] A. Sophie Blee-Goldman commented on KAFKA-16945: [~mjsax] are you sure we don't already

[jira] [Created] (KAFKA-16945) Cleanup StreamsBuilder and TopologyConfig

Matthias J. Sax created KAFKA-16945: --- Summary: Cleanup StreamsBuilder and TopologyConfig Key: KAFKA-16945 URL: https://issues.apache.org/jira/browse/KAFKA-16945 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate

[ https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854557#comment-17854557 ] Chia-Ping Tsai commented on KAFKA-16937: [~gharris1727] thanks for all your sharing. That idea

[jira] [Resolved] (KAFKA-16897) Move OffsetIndexTest and OffsetMapTest to storage module

[ https://issues.apache.org/jira/browse/KAFKA-16897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16897. Fix Version/s: 3.9.0 Resolution: Fixed > Move OffsetIndexTest and OffsetMapT

[jira] [Commented] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate

[ https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854555#comment-17854555 ] Greg Harris commented on KAFKA-16937: - Oh and just one thing that also should be considered

[jira] [Commented] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate

[ https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854554#comment-17854554 ] Greg Harris commented on KAFKA-16937: - [~chia7712] I have no code as I haven't pursued it. But some

[jira] [Commented] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate

[ https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854544#comment-17854544 ] Chia-Ping Tsai commented on KAFKA-16937: [~gharris1727] that sounds good to me. Could you please

[jira] [Resolved] (KAFKA-16858) Flatten SMT throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-16858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-16858. - Resolution: Fixed > Flatten SMT throws NPE > -- > >

[jira] [Updated] (KAFKA-16944) Range assignor doesn't co-partition with stickiness

[ https://issues.apache.org/jira/browse/KAFKA-16944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ritika Reddy updated KAFKA-16944: - Description: When stickiness is considered during range assignments, it is possible

[jira] [Updated] (KAFKA-16944) Range assignor doesn't co-partition with stickiness

[ https://issues.apache.org/jira/browse/KAFKA-16944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ritika Reddy updated KAFKA-16944: - Description: When stickiness is considered during range assignments, it is possible

[jira] [Created] (KAFKA-16944) Range assignor doesn't co-partition with stickiness

Ritika Reddy created KAFKA-16944: Summary: Range assignor doesn't co-partition with stickiness Key: KAFKA-16944 URL: https://issues.apache.org/jira/browse/KAFKA-16944 Project: Kafka Issue

[jira] [Updated] (KAFKA-16943) Synchronously verify Connect worker startup failure in InternalTopicsIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-16943: -- Labels: newbie (was: ) > Synchronously verify Connect worker startup fail

[jira] [Created] (KAFKA-16943) Synchronously verify Connect worker startup failure in InternalTopicsIntegrationTest

Chris Egerton created KAFKA-16943: - Summary: Synchronously verify Connect worker startup failure in InternalTopicsIntegrationTest Key: KAFKA-16943 URL: https://issues.apache.org/jira/browse/KAFKA-16943

[jira] [Commented] (KAFKA-16937) Consider inlineing Time#waitObject to ProducerMetadata#awaitUpdate

[ https://issues.apache.org/jira/browse/KAFKA-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854497#comment-17854497 ] Greg Harris commented on KAFKA-16937: - I wanted to follow the pattern of this method and provide

[jira] [Commented] (KAFKA-16925) stream-table join does not immediately forward expired records on restart

[ https://issues.apache.org/jira/browse/KAFKA-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854483#comment-17854483 ] Ayoub Omari commented on KAFKA-16925: - > Yes, but it's tracked on a per-task basis, and t

[jira] [Created] (KAFKA-16942) Use ConcurrentHashMap in RecordAccumulator#nodeStats

Kuan Po Tseng created KAFKA-16942: - Summary: Use ConcurrentHashMap in RecordAccumulator#nodeStats Key: KAFKA-16942 URL: https://issues.apache.org/jira/browse/KAFKA-16942 Project: Kafka Issue

[jira] [Updated] (KAFKA-16865) Admin.describeTopics behavior change after KIP-966

[ https://issues.apache.org/jira/browse/KAFKA-16865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-16865: --- Fix Version/s: 3.8.0 > Admin.describeTopics behavior change after KIP-

[jira] [Updated] (KAFKA-16865) Admin.describeTopics behavior change after KIP-966

[ https://issues.apache.org/jira/browse/KAFKA-16865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-16865: --- Fix Version/s: 3.9.0 > Admin.describeTopics behavior change after KIP-

[jira] [Resolved] (KAFKA-16865) Admin.describeTopics behavior change after KIP-966

[ https://issues.apache.org/jira/browse/KAFKA-16865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-16865. Resolution: Fixed > Admin.describeTopics behavior change after KIP-

[jira] [Commented] (KAFKA-16862) Refactor ConsumerTaskTest to be deterministic and avoid tight loops

[ https://issues.apache.org/jira/browse/KAFKA-16862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854452#comment-17854452 ] Wang Xiaoqing commented on KAFKA-16862: --- Hi, I have implemented the changes in PR #16303 "

[jira] [Commented] (KAFKA-16781) Expose advertised.listeners in controller node

[ https://issues.apache.org/jira/browse/KAFKA-16781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854408#comment-17854408 ] Gantigmaa Selenge commented on KAFKA-16781: --- [~frankvicky] Hi, are you still planning to work

[jira] [Updated] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-13421: --- Priority: Major (was: Blocker) > Fix > ConsumerBoun

[jira] [Commented] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854404#comment-17854404 ] Philip Nee commented on KAFKA-13421: the test is disabled, can we make this non-blocker? >

[jira] [Commented] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854401#comment-17854401 ] Ksolves commented on KAFKA-2939: We already use INFO level logging for unused configurations

[jira] [Commented] (KAFKA-8031) Flaky Test UserClientIdQuotaTest#testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854382#comment-17854382 ] Igor Soarez commented on KAFKA-8031: Another instance https://ci-builds.apache.org/blue

[jira] [Created] (KAFKA-16941) Flaky test - testDynamicBrokerConfigUpdateUsingKraft [1] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT – kafka.admin.ConfigCommandIntegrationTest

URL: https://issues.apache.org/jira/browse/KAFKA-16941 Project: Kafka Issue Type: Test Reporter: Igor Soarez https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-16077/4/tests/ {code:java

[jira] [Commented] (KAFKA-15945) Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest

[ https://issues.apache.org/jira/browse/KAFKA-15945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854380#comment-17854380 ] Igor Soarez commented on KAFKA-15945: - Another instance https://ci-builds.apache.org/blue

[jira] [Commented] (KAFKA-16634) Flaky test - testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest

[ https://issues.apache.org/jira/browse/KAFKA-16634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854379#comment-17854379 ] Igor Soarez commented on KAFKA-16634: - Failed again:   {code:java

[jira] [Created] (KAFKA-16940) Flaky test "testNoConsumeWithDescribeAclViaSubscribe(String).quorum=kraft" – kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest

URL: https://issues.apache.org/jira/browse/KAFKA-16940 Project: Kafka Issue Type: Test Reporter: Igor Soarez In [https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-16077/4/tests/]   {code:java} java.util.concurrent.Executio

[jira] [Created] (KAFKA-16939) Revisit ConfigCommandIntegrationTest

Chia-Ping Tsai created KAFKA-16939: -- Summary: Revisit ConfigCommandIntegrationTest Key: KAFKA-16939 URL: https://issues.apache.org/jira/browse/KAFKA-16939 Project: Kafka Issue Type: Test

[jira] [Updated] (KAFKA-16938) non-dynamic props gets corrupted due to circular reference between DynamicBrokerConfig and DynamicConfig

[ https://issues.apache.org/jira/browse/KAFKA-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-16938: --- Description: DynamicBrokerConfig has circular reference with DynamicConfig. The following

[jira] [Assigned] (KAFKA-16938) non-dynamic props gets corrupted due to circular reference between DynamicBrokerConfig and DynamicConfig

[ https://issues.apache.org/jira/browse/KAFKA-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-16938: -- Assignee: TengYao Chi (was: Chia-Ping Tsai) > non-dynamic props gets corrupted

[jira] [Commented] (KAFKA-16938) non-dynamic props gets corrupted due to circular reference between DynamicBrokerConfig and DynamicConfig

[ https://issues.apache.org/jira/browse/KAFKA-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854316#comment-17854316 ] TengYao Chi commented on KAFKA-16938: - Gentle ping [~chia7712] , if you haven't start working

  1   2   3   4   5   6   7   8   9   10   >