[jira] [Created] (KAFKA-12308) ConfigDef.parseType deadlock

cosmozhu created KAFKA-12308: Summary: ConfigDef.parseType deadlock Key: KAFKA-12308 URL: https://issues.apache.org/jira/browse/KAFKA-12308 Project: Kafka Issue Type: Bug Components: co

[GitHub] [kafka] feyman2016 opened a new pull request #10076: KAFKA-9689 Automatic broker version detection to initialize stream client

feyman2016 opened a new pull request #10076: URL: https://github.com/apache/kafka/pull/10076 Initial commit of KAFKA-9689, support 1). client feature version publish 2). feature version detection. Test coverage and dynamic feature version switch need to be added ### Commit

[GitHub] [kafka] dengziming commented on pull request #10068: MINOR: StopReplicaResp and StopReplicaReq Test should cover all available version

dengziming commented on pull request #10068: URL: https://github.com/apache/kafka/pull/10068#issuecomment-774601620 Failures seem unrelated to this pr. This is an automated message from the Apache Git Service. To respond to t

[GitHub] [kafka] dengziming opened a new pull request #10075: KAFKA-12251: Add topicId and remove topic name in stopReplicaRep and stopReplicaResp

dengziming opened a new pull request #10075: URL: https://github.com/apache/kafka/pull/10075 *More detailed description of your change* 1. Add topic id and remove topicName in stopReplicaRep/stopReplicaResp 2. bump IBPversion, old-version broker will reply `UNSUPPORTED_VERSION` on new

[GitHub] [kafka] rohitrmd commented on a change in pull request #9744: KAFKA-10062: Add a method to retrieve the current timestamp as known by the Streams app

rohitrmd commented on a change in pull request #9744: URL: https://github.com/apache/kafka/pull/9744#discussion_r571532911 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java ## @@ -45,7 +45,6 @@ private boolean i

[GitHub] [kafka] ijuma commented on a change in pull request #10066: KAFKA-12278; Ensure exposed api versions are consistent within listener scopes

ijuma commented on a change in pull request #10066: URL: https://github.com/apache/kafka/pull/10066#discussion_r571511300 ## File path: generator/src/main/java/org/apache/kafka/message/RequestApiScope.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software Foundation (

[GitHub] [kafka] hachikuji commented on a change in pull request #10066: KAFKA-12278; Ensure exposed api versions are consistent within listener scopes

hachikuji commented on a change in pull request #10066: URL: https://github.com/apache/kafka/pull/10066#discussion_r571501194 ## File path: generator/src/main/java/org/apache/kafka/message/RequestApiScope.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [kafka] hachikuji commented on a change in pull request #10066: KAFKA-12278; Ensure exposed api versions are consistent within listener scopes

hachikuji commented on a change in pull request #10066: URL: https://github.com/apache/kafka/pull/10066#discussion_r571501194 ## File path: generator/src/main/java/org/apache/kafka/message/RequestApiScope.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [kafka] hachikuji commented on a change in pull request #10066: KAFKA-12278; Ensure exposed api versions are consistent within listener scopes

hachikuji commented on a change in pull request #10066: URL: https://github.com/apache/kafka/pull/10066#discussion_r571500369 ## File path: checkstyle/import-control.xml ## @@ -99,6 +100,7 @@ + Review comment: Hmm.. Do you have any ideas? I

[jira] [Created] (KAFKA-12307) Wrap non-fatal exception as CommitFailedException when thrown from commitTxn

Boyang Chen created KAFKA-12307: --- Summary: Wrap non-fatal exception as CommitFailedException when thrown from commitTxn Key: KAFKA-12307 URL: https://issues.apache.org/jira/browse/KAFKA-12307 Project: K

[GitHub] [kafka] ijuma commented on a change in pull request #10066: KAFKA-12278; Ensure exposed api versions are consistent within listener scopes

ijuma commented on a change in pull request #10066: URL: https://github.com/apache/kafka/pull/10066#discussion_r571491307 ## File path: generator/src/main/java/org/apache/kafka/message/RequestApiScope.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software Foundation (

[GitHub] [kafka] abbccdda merged pull request #9579: KAFKA-9751: Forward CreateTopicsRequest for FindCoordinator/Metadata when topic creation is needed

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

[GitHub] [kafka] abbccdda commented on pull request #9579: KAFKA-9751: Forward CreateTopicsRequest for FindCoordinator/Metadata when topic creation is needed

abbccdda commented on pull request #9579: URL: https://github.com/apache/kafka/pull/9579#issuecomment-774542939 only one no-related test failure in connect. Verified on local, will merge the PR. This is an automated message

[jira] [Created] (KAFKA-12306) Avoid using plaintext/hard-coded key while generating secret key

Ying Zhang created KAFKA-12306: -- Summary: Avoid using plaintext/hard-coded key while generating secret key Key: KAFKA-12306 URL: https://issues.apache.org/jira/browse/KAFKA-12306 Project: Kafka

[GitHub] [kafka] rondagostino commented on a change in pull request #10039: MINOR: Defer log recovery until LogManager startup

rondagostino commented on a change in pull request #10039: URL: https://github.com/apache/kafka/pull/10039#discussion_r571470926 ## File path: core/src/main/scala/kafka/log/LogManager.scala ## @@ -352,13 +348,15 @@ class LogManager(logDirs: Seq[File], val numLogsLoaded

[GitHub] [kafka] ijuma commented on a change in pull request #10069: MINOR: Add RaftReplicaManager

ijuma commented on a change in pull request #10069: URL: https://github.com/apache/kafka/pull/10069#discussion_r571453212 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -248,19 +250,19 @@ class ReplicaManager(val config: KafkaConfig, /* epoch of

[GitHub] [kafka] ijuma commented on pull request #9579: KAFKA-9751: Forward CreateTopicsRequest for FindCoordinator/Metadata when topic creation is needed

ijuma commented on pull request #9579: URL: https://github.com/apache/kafka/pull/9579#issuecomment-774499237 I triggered a new build. Is there a reason why you aborted the previous one @abbccdda? This is an automated message

[GitHub] [kafka] omkreddy closed pull request #10002: MINOR: remove the indent in security doc

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

[GitHub] [kafka] mjsax closed pull request #3601: KAFKA-4218: Add withkey methods to KGroupedTable

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

[GitHub] [kafka] mjsax closed pull request #3599: KAFKA-4218: Add withkey methods to KGroupedStream

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

[GitHub] [kafka] mjsax closed pull request #3600: KAFKA-4218: Add withkey methods to KTable

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

[GitHub] [kafka] mjsax closed pull request #3598: KAFKA-4218: Add withkey methods to KStream

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

[GitHub] [kafka] jeqo commented on a change in pull request #10042: KAFKA-9527: fix NPE when using time-based argument for Stream Resetter

jeqo commented on a change in pull request #10042: URL: https://github.com/apache/kafka/pull/10042#discussion_r571434067 ## File path: core/src/main/scala/kafka/tools/StreamsResetter.java ## @@ -503,7 +505,15 @@ private void resetToDatetime(final Consumer client, final

[jira] [Commented] (KAFKA-9527) Application Reset Tool Returns NPE when --to-datetime or --by-duration are run on --input-topics with empty partitions

[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17280187#comment-17280187 ] Jorge Esteban Quilcate Otoya commented on KAFKA-9527: - [~marcolotz],