[GitHub] [kafka] mnegodaev commented on pull request #11442: KAFKA-7883 add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect

2022-07-27 Thread GitBox
mnegodaev commented on PR #11442: URL: https://github.com/apache/kafka/pull/11442#issuecomment-1197690519 @rhauch @mimaison @kkonstantine @pjmagee I've started a vote for the KIP-855: https://lists.apache.org/thread/b0cdofxhl7p84k14wvhtrhd0r1z8qzpk Please vote for it if you're agree. --

[GitHub] [kafka] clolov commented on pull request #12285: KAFKA-14001: Migrate streams module to JUnit 5 - Part 1

2022-07-27 Thread GitBox
clolov commented on PR #12285: URL: https://github.com/apache/kafka/pull/12285#issuecomment-1197688699 Well somewhere between reading the comments, having a discussion and typing my response I confused the options. I don't see why allowing JUnit 4 tests to run alongside JUnit 5 tests

[GitHub] [kafka] dplavcic commented on pull request #10881: KAFKA-12947 Replace EasyMock and PowerMock with Mockito for Streams…

2022-07-27 Thread GitBox
dplavcic commented on PR #10881: URL: https://github.com/apache/kafka/pull/10881#issuecomment-1197640646 > Thank you for the reply @cadonna! Okay, I will wait for a week starting today and I will try to reach out to @wycc over email as well should I manage to find it across GitHub or JI

[GitHub] [kafka] dplavcic opened a new pull request, #12449: KAFKA-12947 [WIP]: Replace PowerMock with Mockito in TableSourceNodeTest

2022-07-27 Thread GitBox
dplavcic opened a new pull request, #12449: URL: https://github.com/apache/kafka/pull/12449 Based on the [Replace EasyMock and PowerMock with Mockito Jira](https://issues.apache.org/jira/browse/KAFKA-7438 ) ticket: >Development of EasyMock and PowerMock has stagnated while Mockito

[jira] [Assigned] (KAFKA-12947) Replace EasyMock and PowerMock with Mockito for StreamsMetricsImplTest ...

2022-07-27 Thread Dalibor Plavcic (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dalibor Plavcic reassigned KAFKA-12947: --- Assignee: Dalibor Plavcic (was: YI-CHEN WANG) > Replace EasyMock and PowerMock wit

[GitHub] [kafka] showuon commented on pull request #12392: KAFKA-14053: Transactional producer should bump the epoch and skip ab…

2022-07-27 Thread GitBox
showuon commented on PR #12392: URL: https://github.com/apache/kafka/pull/12392#issuecomment-1197620235 I'll review it this week. Sorry for the delay. -- 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

[GitHub] [kafka] C0urante merged pull request #12309: KAFKA-14007: Invoking connect headers.close method on shutdown

2022-07-27 Thread GitBox
C0urante merged PR #12309: URL: https://github.com/apache/kafka/pull/12309 -- 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-unsubscr...@kafka.apache

[GitHub] [kafka] C0urante commented on pull request #12309: KAFKA-14007: Invoking connect headers.close method on shutdown

2022-07-27 Thread GitBox
C0urante commented on PR #12309: URL: https://github.com/apache/kafka/pull/12309#issuecomment-1197579201 @vamossagar12 ah yeah, thanks for the ping! I'll merge this one tonight and take a final look at https://github.com/apache/kafka/pull/12321 tomorrow; please ping me again if there's no a

[GitHub] [kafka] niket-goel commented on a diff in pull request #12448: KAFKA-14114: Adding Metadata Log Processing Error Related Metrics

2022-07-27 Thread GitBox
niket-goel commented on code in PR #12448: URL: https://github.com/apache/kafka/pull/12448#discussion_r931715659 ## core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala: ## @@ -169,6 +174,10 @@ class BrokerMetadataListener( _delta.finishSnapshot()

[GitHub] [kafka] niket-goel opened a new pull request, #12448: KAFKA-14114: Adding Metadata Log Processing Error Related Metrics

2022-07-27 Thread GitBox
niket-goel opened a new pull request, #12448: URL: https://github.com/apache/kafka/pull/12448 This PR adds in 3 metrics as described in KIP-859 * kafka.server:type=broker-metadata-metrics,name=publisher-error-count * kafka.server:type=broker-metadata-metrics,name=listener-batch-load-er

[GitHub] [kafka] vamossagar12 commented on pull request #12354: Kafka 13816: Downgrading Connect rebalancing protocol from incremental to eager causes duplicate task instances

2022-07-27 Thread GitBox
vamossagar12 commented on PR #12354: URL: https://github.com/apache/kafka/pull/12354#issuecomment-1197548911 @C0urante no worries.. i am looking at a few other items and not this one currently. i will try to get to this later on. Thanks! -- This is an automated message from the Apache Git

[GitHub] [kafka] vamossagar12 commented on pull request #12309: KAFKA-14007: Invoking connect headers.close method on shutdown

2022-07-27 Thread GitBox
vamossagar12 commented on PR #12309: URL: https://github.com/apache/kafka/pull/12309#issuecomment-1197548178 @C0urante same as the other PR, I think you can merge this now :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [kafka] vamossagar12 commented on pull request #12321: KAFKA-14012: Adding null checks for cases when closeQuietly was being passed a lambda object

2022-07-27 Thread GitBox
vamossagar12 commented on PR #12321: URL: https://github.com/apache/kafka/pull/12321#issuecomment-1197547782 @C0urante i believe now even you might be able to merge this :D -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (KAFKA-13995) Does Kafka support Network File System (NFS)? Is it recommended in Production?

2022-07-27 Thread Sandy Wilbourn (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572187#comment-17572187 ] Sandy Wilbourn commented on KAFKA-13995: I'd like an answer to this question as

[GitHub] [kafka] guozhangwang merged pull request #12439: KAFKA-10199: Further refactor task lifecycle management

2022-07-27 Thread GitBox
guozhangwang merged PR #12439: URL: https://github.com/apache/kafka/pull/12439 -- 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-unsubscr...@kafka.ap

[GitHub] [kafka] C0urante commented on pull request #11783: KAFKA-10000: System tests (KIP-618)

2022-07-27 Thread GitBox
C0urante commented on PR #11783: URL: https://github.com/apache/kafka/pull/11783#issuecomment-1197421645 @showuon any news? Hoping we can get this merged and backported soon so that the stability of 3.3 isn't impacted; let me know if there's anything I can do to help. -- This is an autom

[jira] [Commented] (KAFKA-13586) ConfigExceptions thrown by FileConfigProvider during connector/task startup crash worker

2022-07-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572144#comment-17572144 ] Chris Egerton commented on KAFKA-13586: --- Dan Stelljes (@dstelljes on GitHub) is wo

[GitHub] [kafka] C0urante commented on pull request #12295: KAFKA-13586: Prevent exception thrown during connector update from crashing distributed herder

2022-07-27 Thread GitBox
C0urante commented on PR #12295: URL: https://github.com/apache/kafka/pull/12295#issuecomment-1197417566 By the way, @dstelljes, do you have an account on the project Jira? I'd like to assign the ticket it to you to indicate that it's being worked on but I can't seem to find an account. -

[jira] [Assigned] (KAFKA-13586) ConfigExceptions thrown by FileConfigProvider during connector/task startup crash worker

2022-07-27 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13586: - Assignee: Chris Egerton > ConfigExceptions thrown by FileConfigProvider during connecto

[GitHub] [kafka] C0urante commented on pull request #12295: KAFKA-13586: Prevent exception thrown during connector update from crashing distributed herder

2022-07-27 Thread GitBox
C0urante commented on PR #12295: URL: https://github.com/apache/kafka/pull/12295#issuecomment-1197412312 @dstelljes sorry for all the headaches here, hoping things will be easier once we switch over to Mockito. In the meantime, if you're up for it, one workaround is we do away with s

[GitHub] [kafka] C0urante commented on a diff in pull request #12434: KAFKA-14099 - Fix request logs in connect

2022-07-27 Thread GitBox
C0urante commented on code in PR #12434: URL: https://github.com/apache/kafka/pull/12434#discussion_r930423970 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerTest.java: ## @@ -338,6 +341,41 @@ public void testDisableAdminEndpoint() throws IOExce

[GitHub] [kafka] guozhangwang closed pull request #12439: KAFKA-10199: Further refactor task lifecycle management

2022-07-27 Thread GitBox

[jira] [Resolved] (KAFKA-14119) Sensor in metrics has potential thread safety issues

2022-07-27 Thread Eric Wu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Wu resolved KAFKA-14119. - Resolution: Not A Bug > Sensor in metrics has potential thread safety issues > -

[jira] [Commented] (KAFKA-14119) Sensor in metrics has potential thread safety issues

2022-07-27 Thread Eric Wu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572115#comment-17572115 ] Eric Wu commented on KAFKA-14119: - There is a problem with my test, should have used `Wi

[jira] [Created] (KAFKA-14119) Sensor in metrics has potential thread safety issues

2022-07-27 Thread Eric Wu (Jira)
Eric Wu created KAFKA-14119: --- Summary: Sensor in metrics has potential thread safety issues Key: KAFKA-14119 URL: https://issues.apache.org/jira/browse/KAFKA-14119 Project: Kafka Issue Type: Bug

[GitHub] [kafka] vvcephei merged pull request #12437: KAFKA-13769 Add tests for ForeignJoinSubscriptionProcessorSupplier

2022-07-27 Thread GitBox
vvcephei merged PR #12437: URL: https://github.com/apache/kafka/pull/12437 -- 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-unsubscr...@kafka.apache

[GitHub] [kafka] vvcephei commented on pull request #12437: KAFKA-13769 Add tests for ForeignJoinSubscriptionProcessorSupplier

2022-07-27 Thread GitBox
vvcephei commented on PR #12437: URL: https://github.com/apache/kafka/pull/12437#issuecomment-1197237568 Ok, at least we got on passing build that time. The failures are again unrelated: ``` [Build / PowerPC / Run PowerPC Build / org.apache.kafka.common.security.oauthbearer.secured.Re

[GitHub] [kafka] cadonna commented on a diff in pull request #12439: KAFKA-10199: Further refactor task lifecycle management

2022-07-27 Thread GitBox
cadonna commented on code in PR #12439: URL: https://github.com/apache/kafka/pull/12439#discussion_r931465179 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java: ## @@ -480,6 +503,21 @@ private void closeAndRecycleTasks(final Map> tasksToRe

[GitHub] [kafka] cadonna commented on a diff in pull request #12439: KAFKA-10199: Further refactor task lifecycle management

2022-07-27 Thread GitBox
cadonna commented on code in PR #12439: URL: https://github.com/apache/kafka/pull/12439#discussion_r931394153 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java: ## @@ -77,6 +93,22 @@ public void registerTaskError(final Task task, fi

[GitHub] [kafka] cadonna commented on a diff in pull request #12439: KAFKA-10199: Further refactor task lifecycle management

2022-07-27 Thread GitBox
cadonna commented on code in PR #12439: URL: https://github.com/apache/kafka/pull/12439#discussion_r931357457 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java: ## @@ -493,7 +531,9 @@ boolean tryToCompleteRestoration(final long now, final ja

[jira] [Assigned] (KAFKA-14111) Dynamic config update fails for "password" configs in KRaft

2022-07-27 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur reassigned KAFKA-14111: Assignee: David Arthur > Dynamic config update fails for "password" configs in KRaft > --

[jira] [Commented] (KAFKA-14115) Password configs are logged in plaintext in KRaft

2022-07-27 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572073#comment-17572073 ] David Arthur commented on KAFKA-14115: -- [~Prem237] ConfigurationControlManager has

[jira] [Commented] (KAFKA-14115) Password configs are logged in plaintext in KRaft

2022-07-27 Thread Prem Kamal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572061#comment-17572061 ] Prem Kamal commented on KAFKA-14115: Sure, Thanks [~cmccabe] . > Password configs a

[jira] [Assigned] (KAFKA-14115) Password configs are logged in plaintext in KRaft

2022-07-27 Thread Prem Kamal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prem Kamal reassigned KAFKA-14115: -- Assignee: Prem Kamal > Password configs are logged in plaintext in KRaft > --

[jira] [Commented] (KAFKA-14115) Password configs are logged in plaintext in KRaft

2022-07-27 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572049#comment-17572049 ] Colin McCabe commented on KAFKA-14115: -- KafkaConfig is not accessible from the meta

[GitHub] [kafka] cmccabe merged pull request #12443: MINOR: Convert some junit tests to kraft

2022-07-27 Thread GitBox
cmccabe merged PR #12443: URL: https://github.com/apache/kafka/pull/12443 -- 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-unsubscr...@kafka.apache.

[jira] [Created] (KAFKA-14118) Generate and persist storage uuiid

2022-07-27 Thread Jira
José Armando García Sancio created KAFKA-14118: -- Summary: Generate and persist storage uuiid Key: KAFKA-14118 URL: https://issues.apache.org/jira/browse/KAFKA-14118 Project: Kafka

[jira] [Created] (KAFKA-14117) Flaky Test DynamicBrokerReconfigurationTest.testKeyStoreAlter

2022-07-27 Thread Hao Li (Jira)
Hao Li created KAFKA-14117: -- Summary: Flaky Test DynamicBrokerReconfigurationTest.testKeyStoreAlter Key: KAFKA-14117 URL: https://issues.apache.org/jira/browse/KAFKA-14117 Project: Kafka Issue Type

[jira] [Created] (KAFKA-14116) Update and add all of the Kafka Message Schemas

2022-07-27 Thread Jira
José Armando García Sancio created KAFKA-14116: -- Summary: Update and add all of the Kafka Message Schemas Key: KAFKA-14116 URL: https://issues.apache.org/jira/browse/KAFKA-14116 Project: K

[jira] [Reopened] (KAFKA-12566) Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication

2022-07-27 Thread Hao Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Li reopened KAFKA-12566: Somehow this is still happening: ``` [2022-07-27T11:32:04.461Z] MirrorConnectorsIntegrationSSLTest > testRe

[jira] [Commented] (KAFKA-14115) Password configs are logged in plaintext in KRaft

2022-07-27 Thread Prem Kamal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572025#comment-17572025 ] Prem Kamal commented on KAFKA-14115: Hi [~mumrah], We can use our existing method fr

[GitHub] [kafka] fonaid commented on pull request #11886: KAFKA-13730: OAuth access token validation fails if it does not conta…

2022-07-27 Thread GitBox
fonaid commented on PR #11886: URL: https://github.com/apache/kafka/pull/11886#issuecomment-1196972787 @omkreddy Thank you for the review! -- 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 spec

[jira] [Created] (KAFKA-14115) Password configs are logged in plaintext in KRaft

2022-07-27 Thread David Arthur (Jira)
David Arthur created KAFKA-14115: Summary: Password configs are logged in plaintext in KRaft Key: KAFKA-14115 URL: https://issues.apache.org/jira/browse/KAFKA-14115 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14114) KIP-859: Add Metadata Log Processing Error Related Metrics

2022-07-27 Thread Niket Goel (Jira)
Niket Goel created KAFKA-14114: -- Summary: KIP-859: Add Metadata Log Processing Error Related Metrics Key: KAFKA-14114 URL: https://issues.apache.org/jira/browse/KAFKA-14114 Project: Kafka Issue

[jira] [Created] (KAFKA-14113) KIP-856: KRaft Disk Failure Recovery

2022-07-27 Thread Jira
José Armando García Sancio created KAFKA-14113: -- Summary: KIP-856: KRaft Disk Failure Recovery Key: KAFKA-14113 URL: https://issues.apache.org/jira/browse/KAFKA-14113 Project: Kafka

[GitHub] [kafka] Nayana-ibm commented on pull request #11929: MINOR: s390x Stage

2022-07-27 Thread GitBox
Nayana-ibm commented on PR #11929: URL: https://github.com/apache/kafka/pull/11929#issuecomment-1196861605 @mimaison Any update on this please? -- 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] [Commented] (KAFKA-13868) Website updates to satisfy Apache privacy policies

2022-07-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571952#comment-17571952 ] ASF GitHub Bot commented on KAFKA-13868: mimaison merged PR #429: URL: https://g

[GitHub] [kafka] bellemare commented on a diff in pull request #12437: KAFKA-13769 Add tests for ForeignJoinSubscriptionProcessorSupplier

2022-07-27 Thread GitBox
bellemare commented on code in PR #12437: URL: https://github.com/apache/kafka/pull/12437#discussion_r931078820 ## streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplierTest.java: ## @@ -0,0 +1,371 @@ +/* + * Lice

[jira] [Commented] (KAFKA-13868) Website updates to satisfy Apache privacy policies

2022-07-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571930#comment-17571930 ] ASF GitHub Bot commented on KAFKA-13868: showuon commented on PR #429: URL: http

[GitHub] [kafka] vvcephei commented on pull request #12437: KAFKA-13769 Add tests for ForeignJoinSubscriptionProcessorSupplier

2022-07-27 Thread GitBox
vvcephei commented on PR #12437: URL: https://github.com/apache/kafka/pull/12437#issuecomment-1196757702 These failures are certainly unrelated, but I'm going to re-run the tests before merging, since we didn't get a single green build this time. ``` [Build / JDK 8 and Scala 2.12 /

[jira] [Commented] (KAFKA-13868) Website updates to satisfy Apache privacy policies

2022-07-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571900#comment-17571900 ] ASF GitHub Bot commented on KAFKA-13868: divijvaidya commented on PR #429: URL:

[jira] [Commented] (KAFKA-13868) Website updates to satisfy Apache privacy policies

2022-07-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571899#comment-17571899 ] ASF GitHub Bot commented on KAFKA-13868: divijvaidya opened a new pull request,

[GitHub] [kafka] nicolasguyomar opened a new pull request, #12446: MINOR : lower unregistered info to debug

2022-07-27 Thread GitBox
nicolasguyomar opened a new pull request, #12446: URL: https://github.com/apache/kafka/pull/12446 Hi team, This log gets generated quite often depending on the AK component we use, and to my knowledge does not need to be set to INFO, hence proposing we lower to DEBUG Thank yo

[jira] [Updated] (KAFKA-14112) Expose replication-offset-lag Mirror metric

2022-07-27 Thread Elkhan Eminov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elkhan Eminov updated KAFKA-14112: -- Description: The offset lag is the difference of the last replicated record's source offset a

[jira] [Resolved] (KAFKA-13730) OAuth access token validation fails if it does not contain the "sub" claim

2022-07-27 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-13730. --- Fix Version/s: 3.4.0 Resolution: Fixed > OAuth access token validation fails if it does not c

[GitHub] [kafka] omkreddy merged pull request #11886: KAFKA-13730: OAuth access token validation fails if it does not conta…

2022-07-27 Thread GitBox
omkreddy merged PR #11886: URL: https://github.com/apache/kafka/pull/11886 -- 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-unsubscr...@kafka.apache

[GitHub] [kafka] KarolisCibulskis commented on pull request #11886: KAFKA-13730: OAuth access token validation fails if it does not conta…

2022-07-27 Thread GitBox
KarolisCibulskis commented on PR #11886: URL: https://github.com/apache/kafka/pull/11886#issuecomment-1196574321 Hello, does anyone has an idea when this will be merged to trunk and in which release it will be included? -- This is an automated message from the Apache Git Service. To respo

[GitHub] [kafka] vamossagar12 commented on pull request #12306: KAFKA-13976: Improvements for OpenAPI specs

2022-07-27 Thread GitBox
vamossagar12 commented on PR #12306: URL: https://github.com/apache/kafka/pull/12306#issuecomment-1196564092 @tombentley could you plz take a look whenever you get the chance. Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Created] (KAFKA-14112) Expose replication-offset-lag Mirror metric

2022-07-27 Thread Elkhan Eminov (Jira)
Elkhan Eminov created KAFKA-14112: - Summary: Expose replication-offset-lag Mirror metric Key: KAFKA-14112 URL: https://issues.apache.org/jira/browse/KAFKA-14112 Project: Kafka Issue Type: Imp

[GitHub] [kafka] Gerrrr commented on a diff in pull request #12437: KAFKA-13769 Add tests for ForeignJoinSubscriptionProcessorSupplier

2022-07-27 Thread GitBox
Ge commented on code in PR #12437: URL: https://github.com/apache/kafka/pull/12437#discussion_r930774040 ## streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplierTest.java: ## @@ -0,0 +1,371 @@ +/* + * License