[jira] [Created] (KAFKA-16343) Improve tests of streams foreignkey package

2024-03-04 Thread Ayoub Omari (Jira)
Ayoub Omari created KAFKA-16343: --- Summary: Improve tests of streams foreignkey package Key: KAFKA-16343 URL: https://issues.apache.org/jira/browse/KAFKA-16343 Project: Kafka Issue Type:

Re: [PR] KAFKA-14747: record discarded FK join subscription responses [kafka]

2024-03-04 Thread via GitHub
AyoubOm commented on PR #15395: URL: https://github.com/apache/kafka/pull/15395#issuecomment-1978135956 > > Another point, I think there are some missing tests in the foreignkeyjoin package, and problems in naming a test class. For example, ForeignTableJoinProcessorSupplierTest is not

Re: [PR] KAFKA-14589 [3/4] Tests of ConsoleGroupCommand rewritten in java [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on PR #15365: URL: https://github.com/apache/kafka/pull/15365#issuecomment-1978121311 Hello @chia7712 I checked CI results and failures seems unrelated to changes for me. -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on PR #15387: URL: https://github.com/apache/kafka/pull/15387#issuecomment-1978120545 Hello @chia7712 I checked CI results and failures seems unrelated to changes for me. -- This is an automated message from the Apache Git Service. To respond to the message,

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

2024-03-04 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823460#comment-17823460 ] Luke Chen commented on KAFKA-16310: --- Created 2 sub-tasks for compressed and un-compressed records. >

[jira] [Assigned] (KAFKA-16342) Fix compressed records

2024-03-04 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-16342: - Assignee: Luke Chen > Fix compressed records > -- > > Key:

[jira] [Created] (KAFKA-16342) Fix compressed records

2024-03-04 Thread Luke Chen (Jira)
Luke Chen created KAFKA-16342: - Summary: Fix compressed records Key: KAFKA-16342 URL: https://issues.apache.org/jira/browse/KAFKA-16342 Project: Kafka Issue Type: Sub-task Reporter:

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

2024-03-04 Thread Luke Chen (Jira)
Luke Chen created KAFKA-16341: - Summary: Fix un-compressed records Key: KAFKA-16341 URL: https://issues.apache.org/jira/browse/KAFKA-16341 Project: Kafka Issue Type: Sub-task

Re: [PR] KAFKA-15585: DescribeTopicPartitions client side change. [kafka]

2024-03-04 Thread via GitHub
CalvinConfluent commented on PR #15470: URL: https://github.com/apache/kafka/pull/15470#issuecomment-1977980848 As discussed offline, we decided not to implement the pagination handling in this ticket. Here is the load-all-in-memory version to the https://github.com/apache/kafka/pull/15265

[PR] KAFKA-15585: DescribeTopicPartitions client side change. [kafka]

2024-03-04 Thread via GitHub
CalvinConfluent opened a new pull request, #15470: URL: https://github.com/apache/kafka/pull/15470 https://issues.apache.org/jira/browse/KAFKA-15585 Add the support for DescribeTopicPartitions API on the client side. -- This is an automated message from the Apache Git Service. To

Re: [PR] Improve benchmark settings to speed up benchmarking [kafka]

2024-03-04 Thread via GitHub
github-actions[bot] commented on PR #14597: URL: https://github.com/apache/kafka/pull/14597#issuecomment-1977907333 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please ask a committer for review. If the PR has

Re: [PR] MINOR: Expose earliest local timestamp via the GetOffsetShell [kafka]

2024-03-04 Thread via GitHub
github-actions[bot] commented on PR #14788: URL: https://github.com/apache/kafka/pull/14788#issuecomment-1977907254 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please ask a committer for review. If the PR has

Re: [PR] MINOR: Change test logging capture to per-test, reducing jenkins truncation [kafka]

2024-03-04 Thread via GitHub
github-actions[bot] commented on PR #14795: URL: https://github.com/apache/kafka/pull/14795#issuecomment-1977907234 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please ask a committer for review. If the PR has

[jira] [Commented] (KAFKA-15706) KRaft support in DynamicBrokerReconfigurationTest

2024-03-04 Thread CJ Hillbrand (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823401#comment-17823401 ] CJ Hillbrand commented on KAFKA-15706: -- My first work item, so if needed quicker please comment and

[jira] [Assigned] (KAFKA-15706) KRaft support in DynamicBrokerReconfigurationTest

2024-03-04 Thread CJ Hillbrand (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CJ Hillbrand reassigned KAFKA-15706: Assignee: CJ Hillbrand > KRaft support in DynamicBrokerReconfigurationTest >

[jira] [Updated] (KAFKA-16340) Replication factor: 3 larger than available brokers: 1.

2024-03-04 Thread Jianbin Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianbin Chen updated KAFKA-16340: - Description: Setting remote.log.metadata.topic.replication.factor is invalid {code:java}

[jira] [Updated] (KAFKA-16340) Replication factor: 3 larger than available brokers: 1.

2024-03-04 Thread Jianbin Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianbin Chen updated KAFKA-16340: - Description: Setting remote.log.metadata .topic.replication.factor is invalid {code:java}

[jira] [Updated] (KAFKA-16340) Replication factor: 3 larger than available brokers: 1.

2024-03-04 Thread Jianbin Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianbin Chen updated KAFKA-16340: - Description: 设置 remote.log.metadata.topic.replication.factor 是无效的 {code:java} broker.id=1

[jira] [Updated] (KAFKA-16340) Replication factor: 3 larger than available brokers: 1.

2024-03-04 Thread Jianbin Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianbin Chen updated KAFKA-16340: - Description: I'm having trouble setting remote.log.metadata.topic.replication.factor to be

Re: [PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]

2024-03-04 Thread via GitHub
gharris1727 commented on PR #15469: URL: https://github.com/apache/kafka/pull/15469#issuecomment-1977794542 Benchmark | Before ns/op | Before Error | After ns/op | After Error | Speedup -- | -- | -- | -- | -- | -- ValuesBenchmark.testConvertToBoolean | 124.038 | 0.319 | 71.448 | 2.258

Re: [PR] kafka-connect configuration file uses UTF-8 character set. [kafka]

2024-03-04 Thread via GitHub
pedoc commented on PR #15456: URL: https://github.com/apache/kafka/pull/15456#issuecomment-1977791945 > And unfortunately, even though ASCII is a subset of UTF-8, ISO-8859-1 is not, so this is a backwards-incompatible change. Thank you for your clarification, I am very sorry that I

Re: [PR] kafka-connect configuration file uses UTF-8 character set. [kafka]

2024-03-04 Thread via GitHub
pedoc closed pull request #15456: kafka-connect configuration file uses UTF-8 character set. URL: https://github.com/apache/kafka/pull/15456 -- 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

[jira] [Created] (KAFKA-16340) Replication factor: 3 larger than available brokers: 1.

2024-03-04 Thread Jianbin Chen (Jira)
Jianbin Chen created KAFKA-16340: Summary: Replication factor: 3 larger than available brokers: 1. Key: KAFKA-16340 URL: https://issues.apache.org/jira/browse/KAFKA-16340 Project: Kafka

Re: [PR] KAFKA-15417 flip joinSpuriousLookBackTimeMs and emit non-joined items [kafka]

2024-03-04 Thread via GitHub
mjsax commented on code in PR #14426: URL: https://github.com/apache/kafka/pull/14426#discussion_r1511998434 ## streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamOuterJoinTest.java: ## @@ -438,13 +438,13 @@ public void testOrdering() {

[PR] MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions [kafka]

2024-03-04 Thread via GitHub
gharris1727 opened a new pull request, #15469: URL: https://github.com/apache/kafka/pull/15469 The Values class has checkstyle suppressions for NPathComplexity, MethodLength, CyclomaticComplexity, and JavaNCSS. Rather than suppressing these problems, we should refactor the oversize methods

Re: [PR] KAFKA-15417 flip joinSpuriousLookBackTimeMs and emit non-joined items [kafka]

2024-03-04 Thread via GitHub
mjsax commented on PR #14426: URL: https://github.com/apache/kafka/pull/14426#issuecomment-1977704070 Looking into the test, we create `new KafkaStreams(builder.build(streamsConfig), streamsConfig)`, but we don't pass in the mock time object. So KS creates it's own `Time` object, so it's

Re: [PR] KAFKA-15561: Client support for new SubscriptionPattern based subscription [kafka]

2024-03-04 Thread via GitHub
Phuc-Hong-Tran commented on code in PR #15188: URL: https://github.com/apache/kafka/pull/15188#discussion_r1511957999 ## clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java: ## @@ -494,6 +501,14 @@ public void

Re: [PR] KAFKA-16288, KAFKA-16289: Fix Values convertToDecimal exception and parseString corruption [kafka]

2024-03-04 Thread via GitHub
gharris1727 merged PR #15399: URL: https://github.com/apache/kafka/pull/15399 -- 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 unsubscribe, e-mail:

Re: [PR] KAFKA-16288, KAFKA-16289: Fix Values convertToDecimal exception and parseString corruption [kafka]

2024-03-04 Thread via GitHub
gharris1727 commented on PR #15399: URL: https://github.com/apache/kafka/pull/15399#issuecomment-1977694440 Test failures appear unrelated, and the tests pass for me locally. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Resolved] (KAFKA-14747) FK join should record discarded subscription responses

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14747. - Fix Version/s: 3.8.0 Resolution: Fixed > FK join should record discarded

Re: [PR] MINOR: AddPartitionsToTxnManager performance optimizations [kafka]

2024-03-04 Thread via GitHub
splett2 commented on code in PR #15454: URL: https://github.com/apache/kafka/pull/15454#discussion_r1511954682 ## core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala: ## @@ -80,10 +81,9 @@ class AddPartitionsToTxnManager( topicPartitions: Seq[TopicPartition],

Re: [PR] KAFKA-14747: record discarded FK join subscription responses [kafka]

2024-03-04 Thread via GitHub
mjsax commented on PR #15395: URL: https://github.com/apache/kafka/pull/15395#issuecomment-1977692891 Also, thanks for the PR! Merged to `trunk`. -- 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

Re: [PR] KAFKA-14747: record discarded FK join subscription responses [kafka]

2024-03-04 Thread via GitHub
mjsax merged PR #15395: URL: https://github.com/apache/kafka/pull/15395 -- 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 unsubscribe, e-mail:

Re: [PR] KAFKA-14747: record discarded FK join subscription responses [kafka]

2024-03-04 Thread via GitHub
mjsax commented on PR #15395: URL: https://github.com/apache/kafka/pull/15395#issuecomment-1977688896 > Another point, I think there are some missing tests in the foreignkeyjoin package, and problems in naming a test class. For example, ForeignTableJoinProcessorSupplierTest is not testing

Re: [PR] kafka-connect configuration file uses UTF-8 character set. [kafka]

2024-03-04 Thread via GitHub
gharris1727 commented on PR #15456: URL: https://github.com/apache/kafka/pull/15456#issuecomment-1977617900 Hi @pedoc ! I'm sorry that the configuration reader isn't working out-of-the-box for you. This looks to be a problem that we inherited from Java, and we probably can't change

Re: [PR] KAFKA-16100: Add timeout to all the CompletableApplicationEvents [kafka]

2024-03-04 Thread via GitHub
kirktrue commented on PR #15455: URL: https://github.com/apache/kafka/pull/15455#issuecomment-1977608445 @cadonna—please let me know if there are any outstanding concerns on the overall approach or any details in this PR. Thanks! -- This is an automated message from the Apache Git

Re: [PR] KAFKA-16100: Add timeout to all the CompletableApplicationEvents [kafka]

2024-03-04 Thread via GitHub
kirktrue commented on PR #15455: URL: https://github.com/apache/kafka/pull/15455#issuecomment-1977607424 @AndrewJSchofield—please provide clarification on your comments  Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] KAFKA-16100: Add timeout to all the CompletableApplicationEvents [kafka]

2024-03-04 Thread via GitHub
kirktrue commented on code in PR #15455: URL: https://github.com/apache/kafka/pull/15455#discussion_r1511898298 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java: ## @@ -177,7 +177,7 @@ private void process(final

Re: [PR] KAFKA-16100: Add timeout to all the CompletableApplicationEvents [kafka]

2024-03-04 Thread via GitHub
kirktrue commented on code in PR #15455: URL: https://github.com/apache/kafka/pull/15455#discussion_r1511896707 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CommitEvent.java: ## @@ -29,8 +30,8 @@ public abstract class CommitEvent extends

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on code in PR #15387: URL: https://github.com/apache/kafka/pull/15387#discussion_r1511880453 ## server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java: ## @@ -29,8 +29,8 @@ import org.apache.kafka.common.utils.Utils;

Re: [PR] KAFKA-16100: Add timeout to all the CompletableApplicationEvents [kafka]

2024-03-04 Thread via GitHub
kirktrue commented on code in PR #15455: URL: https://github.com/apache/kafka/pull/15455#discussion_r1511880187 ## clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java: ## @@ -199,7 +205,8 @@ public void

Re: [PR] KAFKA-16100: Add timeout to all the CompletableApplicationEvents [kafka]

2024-03-04 Thread via GitHub
kirktrue commented on code in PR #15455: URL: https://github.com/apache/kafka/pull/15455#discussion_r1511879304 ## clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java: ## @@ -170,7 +173,8 @@ public void testSyncCommitEvent() {

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on code in PR #15387: URL: https://github.com/apache/kafka/pull/15387#discussion_r1511877196 ## server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java: ## @@ -29,8 +29,8 @@ import org.apache.kafka.common.utils.Utils;

[PR] MINOR: Resolve SslContextFactory method deprecations [kafka]

2024-03-04 Thread via GitHub
gharris1727 opened a new pull request, #15468: URL: https://github.com/apache/kafka/pull/15468 The SSLUtilsTest uses the deprecated methods SslContextFactory#getNeedClientAuth and #getWantClientAuth. These are only valid in the context of a server, so they were moved to the

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on code in PR #15387: URL: https://github.com/apache/kafka/pull/15387#discussion_r1511869490 ## server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java: ## @@ -29,7 +29,7 @@ import org.apache.kafka.common.utils.Utils;

[jira] [Updated] (KAFKA-16338) Removed Deprecated configs from StreamsConfig

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16338: Description: * "buffered.records.per.partition" were deprecated via

[jira] [Updated] (KAFKA-16338) Removed Deprecated configs from StreamsConfig

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16338: Description: * "buffered.records.per.partition" was deprecated in 3.4 via

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on code in PR #15387: URL: https://github.com/apache/kafka/pull/15387#discussion_r1511863661 ## server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java: ## @@ -29,7 +29,7 @@ import org.apache.kafka.common.utils.Utils;

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on code in PR #15387: URL: https://github.com/apache/kafka/pull/15387#discussion_r1511855485 ## server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java: ## @@ -29,7 +29,7 @@ import org.apache.kafka.common.utils.Utils;

[jira] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: *

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on code in PR #15387: URL: https://github.com/apache/kafka/pull/15387#discussion_r1511846250 ## server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java: ## @@ -29,7 +29,7 @@ import org.apache.kafka.common.utils.Utils;

Re: [PR] KAFKA-14589 [3/4] Tests of ConsoleGroupCommand rewritten in java [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on code in PR #15365: URL: https://github.com/apache/kafka/pull/15365#discussion_r1511850258 ## core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala: ## @@ -23,15 +23,17 @@ import org.apache.kafka.common.{KafkaException,

[jira] [Resolved] (KAFKA-10603) Re-design KStream.process() and K*.transform*() operations

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10603. - Resolution: Fixed > Re-design KStream.process() and K*.transform*() operations >

[jira] [Created] (KAFKA-16339) Remove Deprecated "transformer" methods and classes

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16339: --- Summary: Remove Deprecated "transformer" methods and classes Key: KAFKA-16339 URL: https://issues.apache.org/jira/browse/KAFKA-16339 Project: Kafka

[jira] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: *

[jira] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: *

Re: [PR] KAFKA-14589 [3/4] Tests of ConsoleGroupCommand rewritten in java [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on code in PR #15365: URL: https://github.com/apache/kafka/pull/15365#discussion_r1511828525 ## core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala: ## @@ -72,7 +71,7 @@ import scala.annotation.nowarn import scala.collection.mutable

[jira] [Updated] (KAFKA-12822) Remove Deprecated APIs of Kafka Streams in 4.0

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12822: Component/s: streams-test-utils > Remove Deprecated APIs of Kafka Streams in 4.0 >

[jira] [Created] (KAFKA-16338) Removed Deprecated configs from StreamsConfig

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16338: --- Summary: Removed Deprecated configs from StreamsConfig Key: KAFKA-16338 URL: https://issues.apache.org/jira/browse/KAFKA-16338 Project: Kafka Issue

[jira] [Created] (KAFKA-16337) Remove Deprecates APIs of Kafka Streams in 5.0

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16337: --- Summary: Remove Deprecates APIs of Kafka Streams in 5.0 Key: KAFKA-16337 URL: https://issues.apache.org/jira/browse/KAFKA-16337 Project: Kafka Issue

[jira] [Updated] (KAFKA-12822) Remove Deprecated APIs of Kafka Streams in 4.0

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12822: Description: This is an umbrella ticket that tries to collect all APIs under Kafka

[jira] [Created] (KAFKA-16336) Remove Deprecated metric standby-process-ratio

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16336: --- Summary: Remove Deprecated metric standby-process-ratio Key: KAFKA-16336 URL: https://issues.apache.org/jira/browse/KAFKA-16336 Project: Kafka Issue

[jira] [Updated] (KAFKA-12822) Remove Deprecated APIs of Kafka Streams in 4.0

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12822: Description: This is an umbrella ticket that tries to collect all APIs under Kafka

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on PR #15387: URL: https://github.com/apache/kafka/pull/15387#issuecomment-1977489464 > ConfigCommand -> DynamicBrokerConfig -> LogCleaner ummm, I assume that will not be a issue if we get rid of zk after 4.0 :) -- This is an automated message from the Apache Git

[jira] [Commented] (KAFKA-12689) Remove deprecated EOS configs

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823353#comment-17823353 ] Matthias J. Sax commented on KAFKA-12689: - As commented on

[jira] [Updated] (KAFKA-12822) Remove Deprecated APIs of Kafka Streams in 4.0

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12822: Description: This is an umbrella ticket that tries to collect all APIs under Kafka

[jira] [Created] (KAFKA-16335) Remove Deprecated method on StreamPartitioner

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16335: --- Summary: Remove Deprecated method on StreamPartitioner Key: KAFKA-16335 URL: https://issues.apache.org/jira/browse/KAFKA-16335 Project: Kafka Issue

[jira] [Created] (KAFKA-16334) Remove Deprecated command line option from reset tool

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16334: --- Summary: Remove Deprecated command line option from reset tool Key: KAFKA-16334 URL: https://issues.apache.org/jira/browse/KAFKA-16334 Project: Kafka

[jira] [Created] (KAFKA-16333) Removed Deprecated methods KTable#join

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16333: --- Summary: Removed Deprecated methods KTable#join Key: KAFKA-16333 URL: https://issues.apache.org/jira/browse/KAFKA-16333 Project: Kafka Issue Type:

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on PR #15387: URL: https://github.com/apache/kafka/pull/15387#issuecomment-1977451436 @chia7712 > relation between cleaner configuration and ConfigCommand `ConfigCommand` -> `DynamicBrokerConfig` -> `LogCleaner` -- This is an automated message from the

[jira] [Updated] (KAFKA-16332) Remove Deprecated builder methods for Time/Session/Join/SlidingWindows

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16332: Component/s: streams > Remove Deprecated builder methods for

[jira] [Updated] (KAFKA-16332) Remove Deprecated builder methods for Time/Session/Join/SlidingWindows

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16332: Priority: Blocker (was: Major) > Remove Deprecated builder methods for

[jira] [Created] (KAFKA-16332) Remove Deprecated builder methods for Time/Session/Join/SlidingWindows

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16332: --- Summary: Remove Deprecated builder methods for Time/Session/Join/SlidingWindows Key: KAFKA-16332 URL: https://issues.apache.org/jira/browse/KAFKA-16332

[jira] [Updated] (KAFKA-16332) Remove Deprecated builder methods for Time/Session/Join/SlidingWindows

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16332: Fix Version/s: 4.0.0 > Remove Deprecated builder methods for

[jira] [Commented] (KAFKA-16331) Remove Deprecated EOSv1

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823337#comment-17823337 ] Matthias J. Sax commented on KAFKA-16331: - While I think we should for sure remove

[jira] [Created] (KAFKA-16331) Remove Deprecated EOSv1

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16331: --- Summary: Remove Deprecated EOSv1 Key: KAFKA-16331 URL: https://issues.apache.org/jira/browse/KAFKA-16331 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-16328) Remove Deprecated config from StreamsConfig

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16328: Description: * #retries was deprecated in AK 2.7 – already unused – via

Re: [PR] KAFKA-14589 [3/4] Tests of ConsoleGroupCommand rewritten in java [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on code in PR #15365: URL: https://github.com/apache/kafka/pull/15365#discussion_r1511775382 ## tools/src/test/java/org/apache/kafka/tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java: ## @@ -0,0 +1,91 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (KAFKA-16328) Remove Deprecated config from StreamsConfig

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16328: Summary: Remove Deprecated config from StreamsConfig (was: Remove Deprecated config

[jira] [Updated] (KAFKA-16330) Remove Deprecated methods/variables from TaskId

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16330: Description: Cf

[jira] [Updated] (KAFKA-16329) Remove Deprecated Task/ThreadMetadata classes and related methods

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16329: Description: Deprecated in AK 3.0 via

[jira] [Created] (KAFKA-16330) Remove Deprecated methods/variables from TaskId

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16330: --- Summary: Remove Deprecated methods/variables from TaskId Key: KAFKA-16330 URL: https://issues.apache.org/jira/browse/KAFKA-16330 Project: Kafka Issue

[jira] [Updated] (KAFKA-16329) Remove Deprecated Task/ThreadMetadata classes and related methods

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16329: Description: Deprecated in AK 3.0 via

Re: [PR] KAFKA-14588 Log cleaner configuration move to CleanerConfig [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on PR #15387: URL: https://github.com/apache/kafka/pull/15387#issuecomment-1977417300 > In order to move ConfigCommand to tools we must move all it's dependencies which includes KafkaConfig and other core classes to java. This PR moves log cleaner configuration to

[jira] [Created] (KAFKA-16329) Remove Deprecated Task/ThreadMetadata classes and related methods

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16329: --- Summary: Remove Deprecated Task/ThreadMetadata classes and related methods Key: KAFKA-16329 URL: https://issues.apache.org/jira/browse/KAFKA-16329 Project:

[jira] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: *

Re: [PR] KAFKA-14588 [WIP] ConfigCommand moved to tools [kafka]

2024-03-04 Thread via GitHub
nizhikov commented on PR #15417: URL: https://github.com/apache/kafka/pull/15417#issuecomment-1977401064 Hello @chia7712 Thanks for the feedback. I think we should move step by step. So I prepared two small PR's that move part of the config to the corresponding java

[jira] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: *

[jira] [Resolved] (KAFKA-12831) Remove Deprecated method StateStore#init

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12831. - Resolution: Fixed > Remove Deprecated method StateStore#init >

Re: [PR] KAFKA-14588 [WIP] ConfigCommand moved to tools [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on PR #15417: URL: https://github.com/apache/kafka/pull/15417#issuecomment-1977389731 I feel this migration can be addressed after 4.0 since we can remove zk support. By deleting zk code, `DynamicBrokerConfig` and `KafkaConfig` will not be used by `ConfigCommand`.

[jira] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12829: Description: The following methods were deprecated in version 2.7: *

[jira] [Resolved] (KAFKA-12825) Remove Deprecated method StreamsBuilder#addGlobalStore

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12825. - Resolution: Fixed > Remove Deprecated method StreamsBuilder#addGlobalStore >

[jira] [Updated] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12829: Summary: Remove Deprecated methods can classes of old Processor API (was: Remove

[jira] [Updated] (KAFKA-16328) Remove Deprecated config StreamsConfig#retries

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16328: Summary: Remove Deprecated config StreamsConfig#retries (was: Remove deprecated config

[jira] [Created] (KAFKA-16328) Remove deprecated config StreamsConfig#retries

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16328: --- Summary: Remove deprecated config StreamsConfig#retries Key: KAFKA-16328 URL: https://issues.apache.org/jira/browse/KAFKA-16328 Project: Kafka Issue

Re: [PR] KAFKA-16100: Add timeout to all the CompletableApplicationEvents [kafka]

2024-03-04 Thread via GitHub
cadonna commented on code in PR #15455: URL: https://github.com/apache/kafka/pull/15455#discussion_r1511735767 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java: ## @@ -177,7 +177,7 @@ private void process(final

[jira] [Updated] (KAFKA-16327) Remove Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16327: Priority: Blocker (was: Minor) > Remove Deprecated variable

[jira] [Updated] (KAFKA-16327) Remove Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION

2024-03-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16327: Fix Version/s: 4.0.0 > Remove Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION >

[jira] [Created] (KAFKA-16327) Remove Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION

2024-03-04 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-16327: --- Summary: Remove Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION Key: KAFKA-16327 URL: https://issues.apache.org/jira/browse/KAFKA-16327 Project: Kafka

Re: [PR] [MINOR] remove meaningless lines [kafka]

2024-03-04 Thread via GitHub
chia7712 commented on PR #14423: URL: https://github.com/apache/kafka/pull/14423#issuecomment-1977358577 hi @sangyongchoi welcome to Kafka community. I'm going to close this PR as this is too trivial to be merged. The Kafka docs is a good choice to find out the newbie issue since there are

  1   2   3   >