[jira] [Comment Edited] (KAFKA-8064) Flaky Test DeleteTopicTest #testRecreateTopicAfterDeletion

[ https://issues.apache.org/jira/browse/KAFKA-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285066#comment-17285066 ] Pavol Ipoth edited comment on KAFKA-8064 at 2/16/21, 7:16 AM: -

[jira] [Commented] (KAFKA-8064) Flaky Test DeleteTopicTest #testRecreateTopicAfterDeletion

[ https://issues.apache.org/jira/browse/KAFKA-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285066#comment-17285066 ] Pavol Ipoth commented on KAFKA-8064: i have problems, i have tests for my cluster whe

[GitHub] [kafka] dengziming opened a new pull request #10128: MINOR: remove duplicate code of serializing auto-generated data

dengziming opened a new pull request #10128: URL: https://github.com/apache/kafka/pull/10128 *More detailed description of your change* Inspired by #9964 *Summary of testing strategy (including rationale)* QA ### Committer Checklist (excluded from commit message) - [ ]

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284970#comment-17284970 ] Matthias J. Sax commented on KAFKA-5146: Adding a `streams-examples` module SGTM.

[jira] [Commented] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284969#comment-17284969 ] Matthias J. Sax commented on KAFKA-12323: - To me, setting zero as default timest

[jira] [Updated] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12323: Component/s: streams > Record timestamps not populated in event >

[GitHub] [kafka] jsancio commented on pull request #10063: KAFKA-12258: Add support for splitting appending records

jsancio commented on pull request #10063: URL: https://github.com/apache/kafka/pull/10063#issuecomment-779420827 @mumrah Ready for review. Fixed the size calculation issues that I discovered when implementing this PR. This i

[GitHub] [kafka] jsancio commented on a change in pull request #10063: KAFKA-12258: Add support for splitting appending records

jsancio commented on a change in pull request #10063: URL: https://github.com/apache/kafka/pull/10063#discussion_r576395637 ## File path: raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java ## @@ -79,24 +80,69 @@ public BatchAccumulator( } /**

[jira] [Resolved] (KAFKA-12325) Is Kafka affected by Scala security vulnerability (CVE-2017-15288)?

[ https://issues.apache.org/jira/browse/KAFKA-12325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Stacy resolved KAFKA-12325. Resolution: Not A Problem > Is Kafka affected by Scala security vulnerability (CVE-2017-15288)? >

[jira] [Commented] (KAFKA-12325) Is Kafka affected by Scala security vulnerability (CVE-2017-15288)?

[ https://issues.apache.org/jira/browse/KAFKA-12325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284748#comment-17284748 ] John Stacy commented on KAFKA-12325: [~ijuma] That answers my concern. Thanks. > Is

[jira] [Commented] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284740#comment-17284740 ] Tim Fox commented on KAFKA-3702: Just looking at the code and it seems SSLEngine.closeOut

[GitHub] [kafka] dajac commented on a change in pull request #10082: MINOR: use 'mapKey' to avoid unnecessary grouped data

dajac commented on a change in pull request #10082: URL: https://github.com/apache/kafka/pull/10082#discussion_r576171184 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java ## @@ -2581,10 +2581,10 @@ public DescribeReplicaLogDirsResult de

[GitHub] [kafka] rajinisivaram merged pull request #10127: MINOR: Remove unused LeaderAndIsrResponse.partitions() since it has been replaced with partitionErrors()

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

[GitHub] [kafka] rajinisivaram commented on pull request #10127: MINOR: Remove unused LeaderAndIsrResponse.partitions() since it has been replaced with partitionErrors()

rajinisivaram commented on pull request #10127: URL: https://github.com/apache/kafka/pull/10127#issuecomment-779187289 @dajac Thanks for the review, test failures not related, merging to trunk and 2.8. This is an automated m

[GitHub] [kafka] rajinisivaram opened a new pull request #10127: MINOR: Remove unused LeaderAndIsrResponse.partitions() since it has been replaced with partitionErrors()

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

[GitHub] [kafka] nicolasguyomar closed pull request #10004: MINOR : add memberId to JoinGroup Success message

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

[GitHub] [kafka] nicolasguyomar commented on a change in pull request #10004: MINOR : add memberId to JoinGroup Success message

nicolasguyomar commented on a change in pull request #10004: URL: https://github.com/apache/kafka/pull/10004#discussion_r576009505 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -591,7 +591,7 @@ public void handle