[jira] [Created] (KAFKA-14494) Kafka Java client can't send data when behind SOCKS proxy - while native client can

2022-12-14 Thread Oleg Zhovtanyuk (Jira)
Oleg Zhovtanyuk created KAFKA-14494: --- Summary: Kafka Java client can't send data when behind SOCKS proxy - while native client can Key: KAFKA-14494 URL: https://issues.apache.org/jira/browse/KAFKA-14494

[GitHub] [kafka] ijuma commented on pull request #12890: KAFKA-14414: Remove unnecessary usage of ObjectSerializationCache

2022-12-14 Thread GitBox
ijuma commented on PR #12890: URL: https://github.com/apache/kafka/pull/12890#issuecomment-1352675158 More details on identity hash code here: https://shipilev.net/jvm/anatomy-quarks/26-identity-hash-code/ -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [kafka] ijuma commented on pull request #12890: KAFKA-14414: Remove unnecessary usage of ObjectSerializationCache

2022-12-14 Thread GitBox
ijuma commented on PR #12890: URL: https://github.com/apache/kafka/pull/12890#issuecomment-1352674511 Out of curiosity, what profiler was used to compute this? Also, did we see an actual improvement (eg was cpu usage or latency lower after the change)? I ask because profilers are known to

[jira] [Commented] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2022-12-14 Thread Werner Daehn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647871#comment-17647871 ] Werner Daehn commented on KAFKA-4852: - Agree, it is resolved. > ByteBufferSerializer not compatible

[GitHub] [kafka] satishd commented on a diff in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

2022-12-14 Thread GitBox
satishd commented on code in PR #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r1049205016 ## core/src/main/scala/kafka/server/ReplicaFetcherThread.scala: ## @@ -192,4 +204,140 @@ class ReplicaFetcherThread(name: String,

[jira] [Updated] (KAFKA-14465) java.lang.NumberFormatException: For input string: "index"

2022-12-14 Thread jianbin.chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jianbin.chen updated KAFKA-14465: - Attachment: image-2022-12-15-12-26-24-718.png > java.lang.NumberFormatException: For input

[jira] [Updated] (KAFKA-14465) java.lang.NumberFormatException: For input string: "index"

2022-12-14 Thread jianbin.chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jianbin.chen updated KAFKA-14465: - Description: {code:java} [2022-12-13 07:12:20,369] WARN [Log partition=fp_sg_flow_copy-1,

[jira] [Updated] (KAFKA-14077) KRaft should support recovery from failed disk

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14077: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KRaft should

[jira] [Updated] (KAFKA-13602) Allow to broadcast a result record

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13602: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Allow to

[jira] [Updated] (KAFKA-13602) Allow to broadcast a result record

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13602: --- Labels: kip newbie++ (was: needs-kip newbie++) > Allow to broadcast a

[jira] [Reopened] (KAFKA-13602) Allow to broadcast a result record

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-13602: Reverting in 3.4 due to logging-related perf/security issue, and some open

[jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647830#comment-17647830 ] A. Sophie Blee-Goldman commented on KAFKA-12319: bumping this to 3.5.0 as we are past

[jira] [Updated] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8280: -- Fix Version/s: 3.5.0 (was: 3.4.0) > Flaky Test

[jira] [Updated] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-6527: -- Fix Version/s: 3.5.0 (was: 3.4.0) > Transient failure

[jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-7957: -- Fix Version/s: 3.5.0 (was: 3.4.0) > Flaky Test

[jira] [Updated] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12319: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Flaky test >

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

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647828#comment-17647828 ] A. Sophie Blee-Goldman commented on KAFKA-13421: bumping this to 3.5.0 as we are past

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

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13421: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Fix >

[jira] [Resolved] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-13736. Resolution: Fixed > Flaky

[jira] [Updated] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13736: --- Fix Version/s: (was: 3.4.0) > Flaky

[jira] [Commented] (KAFKA-13950) Resource leak at multiple places in the code

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647827#comment-17647827 ] A. Sophie Blee-Goldman commented on KAFKA-13950: Bumping this to 3.5.0 as we are past

[jira] [Updated] (KAFKA-13950) Resource leak at multiple places in the code

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13950: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Resource leak at

[jira] [Commented] (KAFKA-14186) Add unit tests for BatchFileWriter

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647826#comment-17647826 ] A. Sophie Blee-Goldman commented on KAFKA-14186: [~mumrah] bumping this to 3.5.0 as we

[jira] [Updated] (KAFKA-14241) Implement the snapshot cleanup policy

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14241: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Implement the

[jira] [Updated] (KAFKA-14186) Add unit tests for BatchFileWriter

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14186: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Add unit tests

[jira] [Updated] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13588: --- Fix Version/s: 4.0.0 (was: 3.4.0) > We should

[jira] [Commented] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647825#comment-17647825 ] A. Sophie Blee-Goldman commented on KAFKA-7109: --- bumping this to 3.5.0 as we are past code

[jira] [Updated] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-7109: -- Fix Version/s: 3.5.0 (was: 3.4.0) > KafkaConsumer

[jira] [Resolved] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-4852. --- Resolution: Fixed > ByteBufferSerializer not compatible with offsets >

[jira] [Commented] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647824#comment-17647824 ] A. Sophie Blee-Goldman commented on KAFKA-4852: --- [~LSK] [~wdaehn] is there a reason this

[jira] [Commented] (KAFKA-14418) Add safety checks for modifying partitions of __consumer_offsets

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647822#comment-17647822 ] A. Sophie Blee-Goldman commented on KAFKA-14418: [~divijvaidya] I just went ahead and

[jira] [Updated] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14318: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KIP-878:

[jira] [Updated] (KAFKA-14418) Add safety checks for modifying partitions of __consumer_offsets

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14418: --- Fix Version/s: (was: 3.4.0) > Add safety checks for modifying

[jira] [Updated] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14318: --- Labels: kip (was: needs-kip) > KIP-878: Autoscaling for Statically

[jira] [Updated] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14302: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Infinite probing

[jira] [Commented] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647820#comment-17647820 ] A. Sophie Blee-Goldman commented on KAFKA-14302: I did look into this briefly but it was

[jira] [Commented] (KAFKA-14241) Implement the snapshot cleanup policy

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647819#comment-17647819 ] A. Sophie Blee-Goldman commented on KAFKA-14241: [~jagsancio]  bumping this to 3.5.0 as

[jira] [Updated] (KAFKA-14139) Replaced disk can lead to loss of committed data even with non-empty ISR

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14139: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Replaced disk

[jira] [Updated] (KAFKA-14094) KIP-853: KRaft Voters Change

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14094: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KIP-853: KRaft

[jira] [Commented] (KAFKA-14139) Replaced disk can lead to loss of committed data even with non-empty ISR

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647817#comment-17647817 ] A. Sophie Blee-Goldman commented on KAFKA-14139: [~hachikuji]  bumping this to 3.5.0 as

[jira] [Commented] (KAFKA-14094) KIP-853: KRaft Voters Change

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647816#comment-17647816 ] A. Sophie Blee-Goldman commented on KAFKA-14094: [~jagsancio] bumping this to 3.5.0 as

[jira] [Resolved] (KAFKA-14291) KRaft: ApiVersionsResponse doesn't have finalizedFeatures and finalizedFeatureEpoch in KRaft mode

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14291. Resolution: Duplicate Marking this as a duplicate of KAFKA-13990 as

[jira] [Commented] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647815#comment-17647815 ] A. Sophie Blee-Goldman commented on KAFKA-14145: [~jagsancio]  moving this to 3.5.0

[jira] [Updated] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14145: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Faster

[jira] [Updated] (KAFKA-7632) Support Compression Level

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-7632: -- Fix Version/s: (was: 3.4.0) > Support Compression Level >

[jira] [Updated] (KAFKA-14291) KRaft: ApiVersionsResponse doesn't have finalizedFeatures and finalizedFeatureEpoch in KRaft mode

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14291: --- Fix Version/s: (was: 3.4.0) > KRaft: ApiVersionsResponse doesn't have

[jira] [Commented] (KAFKA-7632) Support Compression Level

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647813#comment-17647813 ] A. Sophie Blee-Goldman commented on KAFKA-7632: --- [~dongjin]  Removing the target version as

[jira] [Commented] (KAFKA-12399) Deprecate Log4J Appender

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647811#comment-17647811 ] A. Sophie Blee-Goldman commented on KAFKA-12399: [~dongjin] moving this to 3.5.0 since

[jira] [Updated] (KAFKA-12399) Deprecate Log4J Appender

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12399: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Deprecate Log4J

[jira] [Updated] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12679: --- Fix Version/s: (was: 3.4.0) > Rebalancing a restoring or running task

[jira] [Commented] (KAFKA-13299) Accept listeners that have the same port but use IPv4 vs IPv6

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647810#comment-17647810 ] A. Sophie Blee-Goldman commented on KAFKA-13299: [~mdedetrich-aiven] moving this to

[GitHub] [kafka] akhileshchg opened a new pull request, #12998: KAFKA-14493: Introduce Zk to KRaft migration state machine STUBs in KRaft controller.

2022-12-14 Thread GitBox
akhileshchg opened a new pull request, #12998: URL: https://github.com/apache/kafka/pull/12998 KAFKA-14493: Introduce Zk to KRaft migration state machine STUBs in KRaft controller. This patch introduces a preliminary state machine that can be used by the KRaft controller to drive

[jira] [Updated] (KAFKA-13299) Accept listeners that have the same port but use IPv4 vs IPv6

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13299: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Accept listeners

[jira] [Commented] (KAFKA-13891) sync group failed with rebalanceInProgress error cause rebalance many rounds in coopeartive

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647809#comment-17647809 ] A. Sophie Blee-Goldman commented on KAFKA-13891: Bumping this to 3.5.0 since we're past

[jira] [Updated] (KAFKA-13891) sync group failed with rebalanceInProgress error cause rebalance many rounds in coopeartive

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13891: --- Fix Version/s: 3.5.0 (was: 3.4.0) > sync group

[jira] [Updated] (KAFKA-14038) Optimize calculation of size for log in remote tier

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14038: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Optimize

[jira] [Commented] (KAFKA-14038) Optimize calculation of size for log in remote tier

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647807#comment-17647807 ] A. Sophie Blee-Goldman commented on KAFKA-14038: [~divijvaidya]  bumped to 3.5 as we are

[jira] [Created] (KAFKA-14493) Zk to KRaft migration state machine in KRaft controller

2022-12-14 Thread Akhilesh Chaganti (Jira)
Akhilesh Chaganti created KAFKA-14493: - Summary: Zk to KRaft migration state machine in KRaft controller Key: KAFKA-14493 URL: https://issues.apache.org/jira/browse/KAFKA-14493 Project: Kafka

[jira] [Commented] (KAFKA-14077) KRaft should support recovery from failed disk

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647805#comment-17647805 ] A. Sophie Blee-Goldman commented on KAFKA-14077: [~hachikuji] [~jagsancio] what's the

[jira] [Commented] (KAFKA-14279) Add 3.3.1 to broker/client and stream upgrade/compatibility tests

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647804#comment-17647804 ] A. Sophie Blee-Goldman commented on KAFKA-14279: [~jsancio] why is this marked as a

[jira] [Updated] (KAFKA-12473) Make the "cooperative-sticky, range" as the default assignor

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12473: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Make the

[jira] [Commented] (KAFKA-12886) Enable request forwarding by default

2022-12-14 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647800#comment-17647800 ] A. Sophie Blee-Goldman commented on KAFKA-12886: [~hachikuji] [~jagsancio] what's the

[GitHub] [kafka] dengziming commented on pull request #12993: KAFKA-14471: Move IndexEntry and related to storage module

2022-12-14 Thread GitBox
dengziming commented on PR #12993: URL: https://github.com/apache/kafka/pull/12993#issuecomment-1352473472 > @dengziming do you happen to have cycles to review this PR? Sure, I have added it to my review backlog. -- This is an automated message from the Apache Git Service. To

[GitHub] [kafka] PhantomMaa opened a new pull request, #12997: KAFKA-14492: Extract a method to create LogManager, in order to be overrided by subclass of KafkaServer

2022-12-14 Thread GitBox
PhantomMaa opened a new pull request, #12997: URL: https://github.com/apache/kafka/pull/12997 In our scene, we want to implement a subclass of LogManager, add do some interception like encrypting/auditing. Even more, we want enhance the write log performance in the future. Split

[jira] [Created] (KAFKA-14492) Extract a method to create LogManager, in order to be overrided by subclass of KafkaServer

2022-12-14 Thread Phantom Ma (Jira)
Phantom Ma created KAFKA-14492: -- Summary: Extract a method to create LogManager, in order to be overrided by subclass of KafkaServer Key: KAFKA-14492 URL: https://issues.apache.org/jira/browse/KAFKA-14492

[GitHub] [kafka] satishd commented on a diff in pull request #12989: KAFKA-14469: Fix remote tiered related topic configuration

2022-12-14 Thread GitBox
satishd commented on code in PR #12989: URL: https://github.com/apache/kafka/pull/12989#discussion_r1049118373 ## clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java: ## @@ -75,16 +75,16 @@ public class TopicConfig { "\"delete\" retention policy. This

[GitHub] [kafka] ijuma opened a new pull request, #12996: KAFKA-14472: Move TransactionIndex and related to storage module

2022-12-14 Thread GitBox
ijuma opened a new pull request, #12996: URL: https://github.com/apache/kafka/pull/12996 Follows #12993 and hence draft until that is merged. For broader context on this change, please check: * KAFKA-14470: Move log layer to storage module ### Committer Checklist

[GitHub] [kafka] ijuma commented on pull request #12989: KAFKA-14469: Fix remote tiered related topic configuration

2022-12-14 Thread GitBox
ijuma commented on PR #12989: URL: https://github.com/apache/kafka/pull/12989#issuecomment-1352436760 Thoughts @satishd? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[GitHub] [kafka] ijuma commented on pull request #12995: KAFKA-14396: De-flake memory tests with new TestUtils.restrictMemory

2022-12-14 Thread GitBox
ijuma commented on PR #12995: URL: https://github.com/apache/kafka/pull/12995#issuecomment-1352436236 The challenge is that the JVM continues to be reused for several tests afterwards. Once you get an OOM, it can leave lasting effects. -- This is an automated message from the Apache Git

[GitHub] [kafka] gharris1727 commented on pull request #12995: KAFKA-14396: De-flake memory tests with new TestUtils.restrictMemory

2022-12-14 Thread GitBox
gharris1727 commented on PR #12995: URL: https://github.com/apache/kafka/pull/12995#issuecomment-1352397995 Also something I noticed through removing the close() call: none and gzip each pass the test, despite never having close() called. This appears to be because they allocate no or

[jira] [Resolved] (KAFKA-14395) Add config to configure client supplier for KafkaStreams

2022-12-14 Thread Hao Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Li resolved KAFKA-14395. Resolution: Done > Add config to configure client supplier for KafkaStreams >

[GitHub] [kafka] gharris1727 opened a new pull request, #12995: KAFKA-14396: De-flake memory tests with new TestUtils.restrictMemory

2022-12-14 Thread GitBox
gharris1727 opened a new pull request, #12995: URL: https://github.com/apache/kafka/pull/12995 Rather than relying on measuring Runtime::freeMemory() and calling System.gc(), tests which want to assert that there are to excessive allocations should execute in a restricted-memory

[GitHub] [kafka] jsancio opened a new pull request, #12994: KAFKA-14457; Controller metrics should only expose committed data

2022-12-14 Thread GitBox
jsancio opened a new pull request, #12994: URL: https://github.com/apache/kafka/pull/12994 TODO: Write description ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify

[jira] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams

2022-12-14 Thread RockieRockie (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14405 ] RockieRockie deleted comment on KAFKA-14405: -- was (Author: JIRAUSER289157): Hello :) Do you basically mean that the StreamConfig should always log a warning in the constructor that its

[jira] [Created] (KAFKA-14491) Introduce Versioned Key-Value Stores to Kafka Streams

2022-12-14 Thread Victoria Xia (Jira)
Victoria Xia created KAFKA-14491: Summary: Introduce Versioned Key-Value Stores to Kafka Streams Key: KAFKA-14491 URL: https://issues.apache.org/jira/browse/KAFKA-14491 Project: Kafka Issue

[jira] [Commented] (KAFKA-14490) Consider using UncheckdIOException instead of IOException in the log layer

2022-12-14 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647727#comment-17647727 ] Ismael Juma commented on KAFKA-14490: - Yes, I had seen the raft ticket saying the same before. :) >

[jira] [Commented] (KAFKA-14490) Consider using UncheckdIOException instead of IOException in the log layer

2022-12-14 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-14490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647717#comment-17647717 ] José Armando García Sancio commented on KAFKA-14490: I think this is a good idea.

[jira] [Updated] (KAFKA-14471) Move IndexEntry and related to storage module

2022-12-14 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-14471: Fix Version/s: 3.5.0 > Move IndexEntry and related to storage module >

[GitHub] [kafka] ijuma commented on pull request #12993: KAFKA-14471: Move IndexEntry and related to storage module

2022-12-14 Thread GitBox
ijuma commented on PR #12993: URL: https://github.com/apache/kafka/pull/12993#issuecomment-1352261934 @dengziming do you happen to have cycles to review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [kafka] sndp2693 commented on pull request #9243: Add ConsumerGroupCommand to delete static members

2022-12-14 Thread GitBox
sndp2693 commented on PR #9243: URL: https://github.com/apache/kafka/pull/9243#issuecomment-1352259137 @dajac Yes I had started that as well. I am not sure if anyone looked at it or not. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [kafka] ijuma opened a new pull request, #12993: KAFKA-14471: Move IndexEntry and related to storage module

2022-12-14 Thread GitBox
ijuma opened a new pull request, #12993: URL: https://github.com/apache/kafka/pull/12993 For broader context on this change, please check: * KAFKA-14470: Move log layer to storage module ### Committer Checklist (excluded from commit message) - [ ] Verify design and

[jira] [Created] (KAFKA-14490) Consider using UncheckdIOException instead of IOException in the log layer

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14490: --- Summary: Consider using UncheckdIOException instead of IOException in the log layer Key: KAFKA-14490 URL: https://issues.apache.org/jira/browse/KAFKA-14490 Project:

[jira] [Created] (KAFKA-14489) Adjust visibility of classes moved to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14489: --- Summary: Adjust visibility of classes moved to storage module Key: KAFKA-14489 URL: https://issues.apache.org/jira/browse/KAFKA-14489 Project: Kafka Issue

[jira] [Created] (KAFKA-14484) Move UnifiedLog to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14484: --- Summary: Move UnifiedLog to storage module Key: KAFKA-14484 URL: https://issues.apache.org/jira/browse/KAFKA-14484 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14488) Move log layer tests to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14488: --- Summary: Move log layer tests to storage module Key: KAFKA-14488 URL: https://issues.apache.org/jira/browse/KAFKA-14488 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14487) Move LogManager to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14487: --- Summary: Move LogManager to storage module Key: KAFKA-14487 URL: https://issues.apache.org/jira/browse/KAFKA-14487 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14485) Move LogCleaner to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14485: --- Summary: Move LogCleaner to storage module Key: KAFKA-14485 URL: https://issues.apache.org/jira/browse/KAFKA-14485 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14486) Move LogCleanerManager to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14486: --- Summary: Move LogCleanerManager to storage module Key: KAFKA-14486 URL: https://issues.apache.org/jira/browse/KAFKA-14486 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14482) Move LogLoader to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14482: --- Summary: Move LogLoader to storage module Key: KAFKA-14482 URL: https://issues.apache.org/jira/browse/KAFKA-14482 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14483) Move LocalLog to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14483: --- Summary: Move LocalLog to storage module Key: KAFKA-14483 URL: https://issues.apache.org/jira/browse/KAFKA-14483 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-14481) Move LogSegment/LogSegments to storage module

2022-12-14 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-14481: Summary: Move LogSegment/LogSegments to storage module (was: Move LogSegment/LogSegments to

[jira] [Created] (KAFKA-14481) Move LogSegment/LogSegments to storage

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14481: --- Summary: Move LogSegment/LogSegments to storage Key: KAFKA-14481 URL: https://issues.apache.org/jira/browse/KAFKA-14481 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14480) Move ProducerStateManager to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14480: --- Summary: Move ProducerStateManager to storage module Key: KAFKA-14480 URL: https://issues.apache.org/jira/browse/KAFKA-14480 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-14479) Move CleanerConfig to storage module

2022-12-14 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-14479: Summary: Move CleanerConfig to storage module (was: Move CleanerConfig to storage) > Move

[jira] [Created] (KAFKA-14478) Move LogConfig to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14478: --- Summary: Move LogConfig to storage module Key: KAFKA-14478 URL: https://issues.apache.org/jira/browse/KAFKA-14478 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14479) Move CleanerConfig to storage

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14479: --- Summary: Move CleanerConfig to storage Key: KAFKA-14479 URL: https://issues.apache.org/jira/browse/KAFKA-14479 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14477) Move LogValidator to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14477: --- Summary: Move LogValidator to storage module Key: KAFKA-14477 URL: https://issues.apache.org/jira/browse/KAFKA-14477 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-14477) Move LogValidator to storage module

2022-12-14 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-14477: --- Assignee: Ismael Juma > Move LogValidator to storage module >

[jira] [Created] (KAFKA-14476) Move OffsetMap to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14476: --- Summary: Move OffsetMap to storage module Key: KAFKA-14476 URL: https://issues.apache.org/jira/browse/KAFKA-14476 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14475) Move TimestampIndex/LazyIndex to storage module

2022-12-14 Thread Ismael Juma (Jira)
Ismael Juma created KAFKA-14475: --- Summary: Move TimestampIndex/LazyIndex to storage module Key: KAFKA-14475 URL: https://issues.apache.org/jira/browse/KAFKA-14475 Project: Kafka Issue Type:

  1   2   >