[jira] [Assigned] (KAFKA-13052) Replace uses of SerDes in the docs with Serdes

[ https://issues.apache.org/jira/browse/KAFKA-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Galasyn reassigned KAFKA-13052: - Assignee: James Galasyn > Replace uses of SerDes in the docs with Serdes >

[GitHub] [kafka] JimGalasyn opened a new pull request #11050: KQE-289: Replace SerDe with Serde

JimGalasyn opened a new pull request #11050: URL: https://github.com/apache/kafka/pull/11050 Related: KAFKA-13052. -- 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] showuon commented on a change in pull request #11026: KAFKA-13064: refactor ListConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11026: URL: https://github.com/apache/kafka/pull/11026#discussion_r669628826 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java ## @@ -110,41 +112,97 @@ public String

[GitHub] [kafka] rondagostino commented on pull request #10991: MINOR: system test fix for 3 co-located KRaft controllers

rondagostino commented on pull request #10991: URL: https://github.com/apache/kafka/pull/10991#issuecomment-879886127

[jira] [Comment Edited] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337705#comment-17337705 ] Ismael Juma edited comment on KAFKA-7635 at 7/14/21, 1:15 PM: -- This bug has

[jira] [Comment Edited] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337705#comment-17337705 ] Ismael Juma edited comment on KAFKA-7635 at 7/14/21, 1:14 PM: -- This bug has

[jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17380590#comment-17380590 ] Ismael Juma commented on KAFKA-7635: Has anyone seen this issue with 2.3.0 or newer? > FetcherThread

[jira] [Comment Edited] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337705#comment-17337705 ] Ismael Juma edited comment on KAFKA-7635 at 7/14/21, 1:13 PM: -- This bug has

[jira] [Comment Edited] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337705#comment-17337705 ] Ismael Juma edited comment on KAFKA-7635 at 7/14/21, 1:09 PM: -- This bug has

[jira] [Comment Edited] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337705#comment-17337705 ] Ismael Juma edited comment on KAFKA-7635 at 7/14/21, 1:09 PM: -- This bug has

[jira] [Comment Edited] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337705#comment-17337705 ] Ismael Juma edited comment on KAFKA-7635 at 7/14/21, 1:09 PM: -- This bug has

[GitHub] [kafka] vamossagar12 commented on pull request #10877: KAFKA-12925: adding presfixScan operation for missed implementations

vamossagar12 commented on pull request #10877: URL: https://github.com/apache/kafka/pull/10877#issuecomment-879870668 > I think this looks pretty good (as far as I can tell), but the important thing is going to be the tests, since it's hard to verify just by looking whether we hit every

[GitHub] [kafka] vamossagar12 commented on pull request #10877: KAFKA-12925: adding presfixScan operation for missed implementations

vamossagar12 commented on pull request #10877: URL: https://github.com/apache/kafka/pull/10877#issuecomment-879869625 > @vamossagar12 looks like there's a checkstyle failure that's preventing the tests from running, can you fix that as well? Giving this a pass now Oh.. sorry about

[jira] [Updated] (KAFKA-13033) coordinator not available error should cause add into unmap list to do a new lookup

[ https://issues.apache.org/jira/browse/KAFKA-13033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13033: Attachment: Screenshot 2021-07-14 at 14.20.39.png > coordinator not available error should cause

[jira] [Updated] (KAFKA-13033) coordinator not available error should cause add into unmap list to do a new lookup

[ https://issues.apache.org/jira/browse/KAFKA-13033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13033: Attachment: (was: Screenshot 2021-07-14 at 14.20.39.png) > coordinator not available error

[jira] [Commented] (KAFKA-13037) "Thread state is already PENDING_SHUTDOWN" log spam

[ https://issues.apache.org/jira/browse/KAFKA-13037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17380543#comment-17380543 ] John Gray commented on KAFKA-13037: --- Awesome! Thank you, Sophie. > "Thread state is already

[GitHub] [kafka] showuon commented on a change in pull request #11026: KAFKA-13064: refactor ListConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11026: URL: https://github.com/apache/kafka/pull/11026#discussion_r669554178 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java ## @@ -85,11 +86,12 @@ public String

[GitHub] [kafka] showuon commented on a change in pull request #11026: KAFKA-13064: refactor ListConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11026: URL: https://github.com/apache/kafka/pull/11026#discussion_r669553529 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java ## @@ -110,41 +112,97 @@ public String

[GitHub] [kafka] showuon commented on a change in pull request #11026: KAFKA-13064: refactor ListConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11026: URL: https://github.com/apache/kafka/pull/11026#discussion_r669551754 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java ## @@ -110,41 +112,97 @@ public String

[GitHub] [kafka] showuon commented on a change in pull request #11035: KAFKA-13072: refactor RemoveMembersFromConsumerGroupHandler and tests

showuon commented on a change in pull request #11035: URL: https://github.com/apache/kafka/pull/11035#discussion_r669549464 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/RemoveMembersFromConsumerGroupHandler.java ## @@ -82,52 +83,114 @@ public

[GitHub] [kafka] vamossagar12 commented on a change in pull request #10877: KAFKA-12925: adding presfixScan operation for missed implementations

vamossagar12 commented on a change in pull request #10877: URL: https://github.com/apache/kafka/pull/10877#discussion_r669539634 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java ## @@ -66,6 +68,20 @@ public

[GitHub] [kafka] vamossagar12 commented on a change in pull request #10877: KAFKA-12925: adding presfixScan operation for missed implementations

vamossagar12 commented on a change in pull request #10877: URL: https://github.com/apache/kafka/pull/10877#discussion_r669536336 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java ## @@ -383,6 +387,1002 @@ public void

[GitHub] [kafka] jlprat commented on pull request #11025: Scala 3 Compilation with 2.12 support

jlprat commented on pull request #11025: URL: https://github.com/apache/kafka/pull/11025#issuecomment-879815866 Something doesn't feel right. I tried to add a piece of Scala 3.0 only syntax on the code to really check it compiles with Scala 3.0 but apparently it fails. It seems we will

[jira] [Updated] (KAFKA-13085) Offsets clean up based on largest Timestamp in a Log segment

[ https://issues.apache.org/jira/browse/KAFKA-13085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohamed Aashif updated KAFKA-13085: --- Component/s: log cleaner > Offsets clean up based on largest Timestamp in a Log segment >

[jira] [Updated] (KAFKA-13087) production environment throw huge OutOfOrderSequenceException("Invalid sequence number for new epoch at offset..") when enable idempotent function

[ https://issues.apache.org/jira/browse/KAFKA-13087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangfulibo updated KAFKA-13087: Description: Hi Kafka team, I am a new Kafka user. some basic informations Kafka server

[jira] [Created] (KAFKA-13087) production environment throw huge OutOfOrderSequenceException("Invalid sequence number for new epoch at offset..") when enable idempotent function

huangfulibo created KAFKA-13087: --- Summary: production environment throw huge OutOfOrderSequenceException("Invalid sequence number for new epoch at offset..") when enable idempotent function Key: KAFKA-13087 URL:

[jira] [Created] (KAFKA-13086) Kafka failed to start because of an [Error while reading the checkpoint file]

GangHuo created KAFKA-13086: --- Summary: Kafka failed to start because of an [Error while reading the checkpoint file] Key: KAFKA-13086 URL: https://issues.apache.org/jira/browse/KAFKA-13086 Project: Kafka

[GitHub] [kafka] cadonna commented on a change in pull request #10851: KAFKA-6718 / Rack aware standby task assignor

cadonna commented on a change in pull request #10851: URL: https://github.com/apache/kafka/pull/10851#discussion_r669496452 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java ## @@ -51,12 +57,12 @@

[GitHub] [kafka] tombentley commented on a change in pull request #8259: KAFKA-7421: Ensure Connect's PluginClassLoader is truly parallel capable and resolve deadlock occurrences

tombentley commented on a change in pull request #8259: URL: https://github.com/apache/kafka/pull/8259#discussion_r669496427 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java ## @@ -82,11 +93,19 @@

[GitHub] [kafka] jlprat commented on pull request #11049: MINOR: Fix small warning on javadoc and scaladoc

jlprat commented on pull request #11049: URL: https://github.com/apache/kafka/pull/11049#issuecomment-879785324 While testing if all tasks were working for https://github.com/apache/kafka/pull/11025, I realized some warnings were printed for the JavaDoc and ScalaDoc. There are still

[GitHub] [kafka] showuon commented on a change in pull request #11022: KAFKA-13063: refactor DescribeConsumerGroupsHandler and tests

showuon commented on a change in pull request #11022: URL: https://github.com/apache/kafka/pull/11022#discussion_r669487722 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java ## @@ -151,38 +162,59 @@ public String

[GitHub] [kafka] showuon commented on a change in pull request #11022: KAFKA-13063: refactor DescribeConsumerGroupsHandler and tests

showuon commented on a change in pull request #11022: URL: https://github.com/apache/kafka/pull/11022#discussion_r669487271 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java ## @@ -103,6 +104,12 @@ public String

[GitHub] [kafka] jlprat opened a new pull request #11049: MINOR: Fix small warning on javadoc and scaladoc

jlprat opened a new pull request #11049: URL: https://github.com/apache/kafka/pull/11049 Escape the `>` character in javadoc Escape the `$` character when part of `${}` in scaladoc as this is the way to reference a variable ### Committer Checklist (excluded from commit message)

[GitHub] [kafka] satishd commented on pull request #10280: KAFKA-12554: Refactor Log layer

satishd commented on pull request #10280: URL: https://github.com/apache/kafka/pull/10280#issuecomment-879773476 Thanks @junrao for merging into trunk. Can we also push this to [3.0 branch](https://github.com/apache/kafka/tree/3.0) as we discussed earlier? cc @kowshik -- This is an

[GitHub] [kafka] showuon commented on a change in pull request #11021: KAFKA-13062: Make DeleteConsumerGroupsHandler unmap for COORDINATOR_NOT_AVAILABLE error

showuon commented on a change in pull request #11021: URL: https://github.com/apache/kafka/pull/11021#discussion_r669479150 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupsHandler.java ## @@ -89,46 +91,76 @@ public String

[GitHub] [kafka] showuon commented on a change in pull request #11021: KAFKA-13062: Make DeleteConsumerGroupsHandler unmap for COORDINATOR_NOT_AVAILABLE error

showuon commented on a change in pull request #11021: URL: https://github.com/apache/kafka/pull/11021#discussion_r669478307 ## File path: clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java ## @@ -3179,41 +3179,47 @@ public void

[GitHub] [kafka] showuon commented on a change in pull request #11019: KAFKA-13059: refactor DeleteConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11019: URL: https://github.com/apache/kafka/pull/11019#discussion_r669472461 ## File path: clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandlerTest.java ## @@ -149,4 +191,21 @@ private

[GitHub] [kafka] showuon commented on a change in pull request #11019: KAFKA-13059: refactor DeleteConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11019: URL: https://github.com/apache/kafka/pull/11019#discussion_r669472287 ## File path: clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java ## @@ -3359,23 +3360,23 @@ public void

[GitHub] [kafka] showuon commented on a change in pull request #11019: KAFKA-13059: refactor DeleteConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11019: URL: https://github.com/apache/kafka/pull/11019#discussion_r669471854 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java ## @@ -97,54 +108,79 @@ public

[GitHub] [kafka] showuon commented on a change in pull request #11019: KAFKA-13059: refactor DeleteConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11019: URL: https://github.com/apache/kafka/pull/11019#discussion_r669471550 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java ## @@ -97,54 +108,79 @@ public

[GitHub] [kafka] showuon commented on a change in pull request #11019: KAFKA-13059: refactor DeleteConsumerGroupOffsetsHandler and tests

showuon commented on a change in pull request #11019: URL: https://github.com/apache/kafka/pull/11019#discussion_r669471228 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java ## @@ -97,54 +108,79 @@ public

[jira] [Resolved] (KAFKA-13084) Offsets clean up based on largest Timestamp in a Log segment

[ https://issues.apache.org/jira/browse/KAFKA-13084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohamed Aashif resolved KAFKA-13084. Resolution: Duplicate > Offsets clean up based on largest Timestamp in a Log segment >

[jira] [Updated] (KAFKA-13084) Offsets clean up based on largest Timestamp in a Log segment

[ https://issues.apache.org/jira/browse/KAFKA-13084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohamed Aashif updated KAFKA-13084: --- Description: /~Duplicated~ (was: This is to confirm the behaviour of

[jira] [Updated] (KAFKA-13085) Offsets clean up based on largest Timestamp in a Log segment

[ https://issues.apache.org/jira/browse/KAFKA-13085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohamed Aashif updated KAFKA-13085: --- Component/s: config > Offsets clean up based on largest Timestamp in a Log segment >

[jira] [Updated] (KAFKA-13085) Offsets clean up based on largest Timestamp in a Log segment

[ https://issues.apache.org/jira/browse/KAFKA-13085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohamed Aashif updated KAFKA-13085: --- Component/s: (was: config) > Offsets clean up based on largest Timestamp in a Log

[jira] [Created] (KAFKA-13085) Offsets clean up based on largest Timestamp in a Log segment

Mohamed Aashif created KAFKA-13085: -- Summary: Offsets clean up based on largest Timestamp in a Log segment Key: KAFKA-13085 URL: https://issues.apache.org/jira/browse/KAFKA-13085 Project: Kafka

[jira] [Created] (KAFKA-13084) Offsets clean up based on largest Timestamp in a Log segment

Mohamed Aashif created KAFKA-13084: -- Summary: Offsets clean up based on largest Timestamp in a Log segment Key: KAFKA-13084 URL: https://issues.apache.org/jira/browse/KAFKA-13084 Project: Kafka

[jira] [Resolved] (KAFKA-13049) Log recovery threads use default thread pool naming

[ https://issues.apache.org/jira/browse/KAFKA-13049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley resolved KAFKA-13049. - Fix Version/s: 3.1.0 Resolution: Fixed > Log recovery threads use default thread pool

[jira] [Commented] (KAFKA-13010) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectCommittedOffsetInformation()

[ https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17380444#comment-17380444 ] Bruno Cadonna commented on KAFKA-13010: --- For the future assignee of this ticket: I was able to

[jira] [Updated] (KAFKA-13033) coordinator not available error should cause add into unmap list to do a new lookup

[ https://issues.apache.org/jira/browse/KAFKA-13033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-13033: Fix Version/s: 3.0.0 > coordinator not available error should cause add into unmap list to do a

[GitHub] [kafka] cadonna edited a comment on pull request #10953: MINOR: Default GRACE with Old API should set as 24H minus window-size / inactivity-gap

cadonna edited a comment on pull request #10953: URL: https://github.com/apache/kafka/pull/10953#issuecomment-879704540 I do not agree. If users deploy Streams apps in 2.8 we guarantee retention time T, but when users upgrade the Streams apps to 3.0 we guarantee retention time T+X. We do

[GitHub] [kafka] cadonna commented on pull request #10953: MINOR: Default GRACE with Old API should set as 24H minus window-size / inactivity-gap

cadonna commented on pull request #10953: URL: https://github.com/apache/kafka/pull/10953#issuecomment-879704540 I do not agree. If users deploy Streams apps in 2.8 we guarantee retention time T, but when users upgrade the Streams apps to 3.0 we guarantee retention time T+X. We do not

[GitHub] [kafka] dajac commented on a change in pull request #11019: KAFKA-13059: refactor DeleteConsumerGroupOffsetsHandler and tests

dajac commented on a change in pull request #11019: URL: https://github.com/apache/kafka/pull/11019#discussion_r669398821 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java ## @@ -97,54 +108,79 @@ public String

[GitHub] [kafka] dajac commented on a change in pull request #11021: KAFKA-13062: refactor DeleteConsumerGroupsHandler and tests

dajac commented on a change in pull request #11021: URL: https://github.com/apache/kafka/pull/11021#discussion_r669379080 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupsHandler.java ## @@ -86,47 +87,54 @@ public String

[GitHub] [kafka] cmccabe opened a new pull request #11048: KAFKA-13083: In KRaft mode, fix issue with ISR in manual partition assignments

cmccabe opened a new pull request #11048: URL: https://github.com/apache/kafka/pull/11048 When creating a new topic that includes manually assigned partitions, we must check if the nodes are unfenced before adding them to the new ISR. This PR adds two unit tests of this behavior

[jira] [Created] (KAFKA-13083) In KRaft mode, ISR is set incorrectly when creating a manual partition assignment with fenced broker(s)

Colin McCabe created KAFKA-13083: Summary: In KRaft mode, ISR is set incorrectly when creating a manual partition assignment with fenced broker(s) Key: KAFKA-13083 URL:

[GitHub] [kafka] tang7526 opened a new pull request #11047: MINOR: Remove unnecessary code for WindowStoreBuilder.

tang7526 opened a new pull request #11047: URL: https://github.com/apache/kafka/pull/11047 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade

[jira] [Resolved] (KAFKA-10201) Update codebase to use more inclusive terms

[ https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-10201. - Resolution: Fixed > Update codebase to use more inclusive terms >

[jira] [Resolved] (KAFKA-10589) Rename kafka-replica-verification CLI command line arguments for KIP-629

[ https://issues.apache.org/jira/browse/KAFKA-10589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-10589. - Reviewer: David Jacot Resolution: Fixed > Rename kafka-replica-verification CLI command

[GitHub] [kafka] dajac commented on pull request #11007: KAFKA-10589 Rename kafka-replica-verification CLI command line arguments for KIP-629

dajac commented on pull request #11007: URL: https://github.com/apache/kafka/pull/11007#issuecomment-879641980 Merged to trunk and 3.0. cc @kkonstantine -- 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

[GitHub] [kafka] dajac merged pull request #11007: KAFKA-10589 Rename kafka-replica-verification CLI command line arguments for KIP-629

dajac merged pull request #11007: URL: https://github.com/apache/kafka/pull/11007 -- 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:

[jira] [Resolved] (KAFKA-10588) Rename kafka-console-consumer CLI command line arguments for KIP-629

[ https://issues.apache.org/jira/browse/KAFKA-10588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-10588. - Reviewer: David Jacot Resolution: Fixed > Rename kafka-console-consumer CLI command line

[GitHub] [kafka] dajac commented on pull request #11008: KAFKA-10588 Rename kafka-console-consumer CLI command line arguments for KIP-629

dajac commented on pull request #11008: URL: https://github.com/apache/kafka/pull/11008#issuecomment-879629297 Merged to trunk and to 3.0. cc @kkonstantine -- 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] dajac merged pull request #11008: KAFKA-10588 Rename kafka-console-consumer CLI command line arguments for KIP-629

dajac merged pull request #11008: URL: https://github.com/apache/kafka/pull/11008 -- 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:

[GitHub] [kafka] cmccabe closed pull request #11044: MINOR: Fully specify CompletableFuture type

cmccabe closed pull request #11044: URL: https://github.com/apache/kafka/pull/11044 -- 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:

[GitHub] [kafka] cmccabe commented on pull request #11044: MINOR: Fully specify CompletableFuture type

cmccabe commented on pull request #11044: URL: https://github.com/apache/kafka/pull/11044#issuecomment-879624486 Thanks for the PR. Closing as a duplicate of #11043, since we just committed that one -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [kafka] cmccabe merged pull request #11043: MINOR: fix Scala 2.12 compile failure in ControllerApisTest

cmccabe merged pull request #11043: URL: https://github.com/apache/kafka/pull/11043 -- 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:

<    1   2