[jira] [Created] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread RivenSun (Jira)
RivenSun created KAFKA-13663: Summary: IllegalMonitorStateException in ProducerMetadata.awaitUpdate Key: KAFKA-13663 URL: https://issues.apache.org/jira/browse/KAFKA-13663 Project: Kafka Issue T

[GitHub] [kafka] mimaison merged pull request #11673: KAFKA-13577: Replace easymock with mockito in kafka:core - part 2

2022-02-10 Thread GitBox
mimaison merged pull request #11673: URL: https://github.com/apache/kafka/pull/11673 -- 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

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490022#comment-17490022 ] RivenSun commented on KAFKA-13663: -- Hi [~guozhang] , [~hachikuji] and [~showuon]  Could

[GitHub] [kafka] showuon commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r803442548 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket Serv

[GitHub] [kafka] showuon commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r803442548 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket Serv

[GitHub] [kafka] showuon commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r803442548 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket Serv

[GitHub] [kafka] showuon commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r803447044 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket Serv

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490049#comment-17490049 ] RivenSun commented on KAFKA-13663: -- Notice: Once the obj.wait method is called, even if

[GitHub] [kafka] showuon commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r803449800 ## File path: config/kraft/controller.properties ## @@ -39,10 +39,6 @@ controller.quorum.voters=1@localhost:9093 # listeners = PLAINTEXT://your.host.

[GitHub] [kafka] showuon commented on pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on pull request #11616: URL: https://github.com/apache/kafka/pull/11616#issuecomment-1034670296 @hachikuji , thanks for the comments. I've addressed most of them. Only 1 comment I'm not sure what you mean: https://github.com/apache/kafka/pull/11616#discussion_r801169378 .

[jira] [Resolved] (KAFKA-8153) Streaming application with state stores takes up to 1 hour to restart

2022-02-10 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8153. -- Resolution: Not A Problem > Streaming application with state stores takes up to 1 hour to resta

[jira] [Created] (KAFKA-13664) log.preallocate option causes CorruptRecordException

2022-02-10 Thread Vyacheslav Ksenz (Jira)
Vyacheslav Ksenz created KAFKA-13664: Summary: log.preallocate option causes CorruptRecordException Key: KAFKA-13664 URL: https://issues.apache.org/jira/browse/KAFKA-13664 Project: Kafka

[jira] [Updated] (KAFKA-13664) log.preallocate option causes CorruptRecordException

2022-02-10 Thread Vyacheslav Ksenz (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vyacheslav Ksenz updated KAFKA-13664: - Description: If we create multibroker cluster with log.preallocate option restarting one

[jira] [Updated] (KAFKA-13664) log.preallocate option causes CorruptRecordException

2022-02-10 Thread Vyacheslav Ksenz (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vyacheslav Ksenz updated KAFKA-13664: - Description: If we create multibroker cluster with log.preallocate option restarting one

[GitHub] [kafka] mimaison merged pull request #11744: MINOR: Fix JavaDoc of OffsetIndex#append

2022-02-10 Thread GitBox
mimaison merged pull request #11744: URL: https://github.com/apache/kafka/pull/11744 -- 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

[GitHub] [kafka] mimaison closed pull request #1493: KAFKA-3818: Change Mirror Maker default assignment strategy to round robin

2022-02-10 Thread GitBox
mimaison closed pull request #1493: URL: https://github.com/apache/kafka/pull/1493 -- 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..

[GitHub] [kafka] mimaison commented on pull request #1493: KAFKA-3818: Change Mirror Maker default assignment strategy to round robin

2022-02-10 Thread GitBox
mimaison commented on pull request #1493: URL: https://github.com/apache/kafka/pull/1493#issuecomment-1034751572 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] jeqo commented on pull request #11534: KAFKA-12939: After migrating processors, search the codebase for missed migrations

2022-02-10 Thread GitBox
jeqo commented on pull request #11534: URL: https://github.com/apache/kafka/pull/11534#issuecomment-1034794711 My bad. Should be fixed now 👍🏽 -- 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] dengziming opened a new pull request #11746: MINOR: Use timeout config in KafkaAdminClient

2022-02-10 Thread GitBox
dengziming opened a new pull request #11746: URL: https://github.com/apache/kafka/pull/11746 *More detailed description of your change* Currently we use a fixed value 360 as requestTimeout when creating NetworkClient in KafkaAdminClient, it's better to use the `request.timeout.ms` c

[GitHub] [kafka] dengziming commented on pull request #11746: MINOR: Use timeout config in KafkaAdminClient

2022-02-10 Thread GitBox
dengziming commented on pull request #11746: URL: https://github.com/apache/kafka/pull/11746#issuecomment-1034906293 Hello @dajac, this is a small finding when comparing KafkaConsumer and KafkaAdminClient, In fact, I'm not very confident about this change. PTAL, thank you. -- This is an

[jira] [Commented] (KAFKA-13655) Cannot edit clients page

2022-02-10 Thread Mario Mastrodicasa (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490197#comment-17490197 ] Mario Mastrodicasa commented on KAFKA-13655: The id associated to [https://c

[GitHub] [kafka] tombentley commented on a change in pull request #11674: KAFKA-13577: Replace easymock with mockito in kafka:core - part 3

2022-02-10 Thread GitBox
tombentley commented on a change in pull request #11674: URL: https://github.com/apache/kafka/pull/11674#discussion_r803666411 ## File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala ## @@ -82,44 +82,43 @@ import org.apache.kafka.common.security.auth.{KafkaPrin

[GitHub] [kafka] mimaison commented on a change in pull request #11674: KAFKA-13577: Replace easymock with mockito in kafka:core - part 3

2022-02-10 Thread GitBox
mimaison commented on a change in pull request #11674: URL: https://github.com/apache/kafka/pull/11674#discussion_r803683246 ## File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala ## @@ -82,44 +82,43 @@ import org.apache.kafka.common.security.auth.{KafkaPrinci

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread Luke2 Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490237#comment-17490237 ] Luke2 Chen commented on KAFKA-13663: [~RivenSun] , I'm Luke, sorry that my account s

[jira] [Comment Edited] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread Luke2 Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490237#comment-17490237 ] Luke2 Chen edited comment on KAFKA-13663 at 2/10/22, 1:50 PM:

[GitHub] [kafka] mimaison commented on a change in pull request #7898: KAFKA-9366: Change log4j dependency into log4j2

2022-02-10 Thread GitBox
mimaison commented on a change in pull request #7898: URL: https://github.com/apache/kafka/pull/7898#discussion_r797627738 ## File path: clients/src/test/resources/log4j2.properties ## @@ -12,11 +12,16 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implie

[GitHub] [kafka] dajac commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r803835704 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -699,11 +702,15 @@ public void handle(JoinGr

[GitHub] [kafka] dajac commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
dajac commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r803838565 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java ## @@ -211,7 +211,13 @@ protected void onJo

[GitHub] [kafka] mimaison commented on pull request #1666: [KAFKA-3991]: allow MirrorMaker to have custom producer

2022-02-10 Thread GitBox
mimaison commented on pull request #1666: URL: https://github.com/apache/kafka/pull/1666#issuecomment-1035112473 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #1666: [KAFKA-3991]: allow MirrorMaker to have custom producer

2022-02-10 Thread GitBox
mimaison closed pull request #1666: URL: https://github.com/apache/kafka/pull/1666 -- 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..

[GitHub] [kafka] mimaison commented on pull request #1715: WIP: Add a consumer offset migration tool

2022-02-10 Thread GitBox
mimaison commented on pull request #1715: URL: https://github.com/apache/kafka/pull/1715#issuecomment-1035113425 The old consumer has been removed a long time ago, so I think we can close this PR. -- This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [kafka] mimaison closed pull request #1715: WIP: Add a consumer offset migration tool

2022-02-10 Thread GitBox
mimaison closed pull request #1715: URL: https://github.com/apache/kafka/pull/1715 -- 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..

[GitHub] [kafka] mimaison closed pull request #2665: MINOR: Let MirrorMaker pick up client.id if specified in consumer.properties

2022-02-10 Thread GitBox
mimaison closed pull request #2665: URL: https://github.com/apache/kafka/pull/2665 -- 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..

[GitHub] [kafka] mimaison commented on pull request #2665: MINOR: Let MirrorMaker pick up client.id if specified in consumer.properties

2022-02-10 Thread GitBox
mimaison commented on pull request #2665: URL: https://github.com/apache/kafka/pull/2665#issuecomment-1035114899 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #3151: KAFKA-5331:MirrorMaker can't guarantee data is consistent between clusters

2022-02-10 Thread GitBox
mimaison closed pull request #3151: URL: https://github.com/apache/kafka/pull/3151 -- 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..

[GitHub] [kafka] mimaison commented on pull request #3151: KAFKA-5331:MirrorMaker can't guarantee data is consistent between clusters

2022-02-10 Thread GitBox
mimaison commented on pull request #3151: URL: https://github.com/apache/kafka/pull/3151#issuecomment-1035115617 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #6563: KAFKA-8226: New MirrorMaker option partition.to.partition

2022-02-10 Thread GitBox
mimaison closed pull request #6563: URL: https://github.com/apache/kafka/pull/6563 -- 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..

[GitHub] [kafka] mimaison commented on pull request #6563: KAFKA-8226: New MirrorMaker option partition.to.partition

2022-02-10 Thread GitBox
mimaison commented on pull request #6563: URL: https://github.com/apache/kafka/pull/6563#issuecomment-1035115854 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison commented on pull request #2394: KAFKA-4668: Replicate mirrormaker topics from earliest

2022-02-10 Thread GitBox
mimaison commented on pull request #2394: URL: https://github.com/apache/kafka/pull/2394#issuecomment-1035116196 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #2394: KAFKA-4668: Replicate mirrormaker topics from earliest

2022-02-10 Thread GitBox
mimaison closed pull request #2394: URL: https://github.com/apache/kafka/pull/2394 -- 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..

[GitHub] [kafka] mimaison commented on pull request #5935: KAFKA-7665: Replace BaseConsumerRecord with ConsumerRecord in MM

2022-02-10 Thread GitBox
mimaison commented on pull request #5935: URL: https://github.com/apache/kafka/pull/5935#issuecomment-1035117159 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #5935: KAFKA-7665: Replace BaseConsumerRecord with ConsumerRecord in MM

2022-02-10 Thread GitBox
mimaison closed pull request #5935: URL: https://github.com/apache/kafka/pull/5935 -- 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..

[GitHub] [kafka] mimaison commented on pull request #5902: Kafka_7615

2022-02-10 Thread GitBox
mimaison commented on pull request #5902: URL: https://github.com/apache/kafka/pull/5902#issuecomment-1035117402 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #5902: Kafka_7615

2022-02-10 Thread GitBox
mimaison closed pull request #5902: URL: https://github.com/apache/kafka/pull/5902 -- 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..

[GitHub] [kafka] dajac merged pull request #11742: KAFKA-13636: Fix for the group coordinator issue where the offsets are deleted for unstable groups

2022-02-10 Thread GitBox
dajac merged pull request #11742: URL: https://github.com/apache/kafka/pull/11742 -- 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...

[GitHub] [kafka] mimaison commented on pull request #2161: KAFKA-4307 Inconsistent parameters between console producer and consumer

2022-02-10 Thread GitBox
mimaison commented on pull request #2161: URL: https://github.com/apache/kafka/pull/2161#issuecomment-1035125665 I believe this has been addressed by [KIP-499](https://cwiki.apache.org/confluence/display/KAFKA/KIP-499+-+Unify+connection+name+flag+for+command+line+tool), so closing this PR.

[GitHub] [kafka] mimaison closed pull request #2161: KAFKA-4307 Inconsistent parameters between console producer and consumer

2022-02-10 Thread GitBox
mimaison closed pull request #2161: URL: https://github.com/apache/kafka/pull/2161 -- 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..

[GitHub] [kafka] mimaison closed pull request #1912: KAFKA-4201: Add an `assignment.strategy` option to new-consumer-based Mirror Maker

2022-02-10 Thread GitBox
mimaison closed pull request #1912: URL: https://github.com/apache/kafka/pull/1912 -- 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..

[GitHub] [kafka] mimaison commented on pull request #1912: KAFKA-4201: Add an `assignment.strategy` option to new-consumer-based Mirror Maker

2022-02-10 Thread GitBox
mimaison commented on pull request #1912: URL: https://github.com/apache/kafka/pull/1912#issuecomment-1035130631 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #8862: Dev/t toacin/2 4 1 mirror maker

2022-02-10 Thread GitBox
mimaison closed pull request #8862: URL: https://github.com/apache/kafka/pull/8862 -- 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..

[GitHub] [kafka] mimaison commented on pull request #8862: Dev/t toacin/2 4 1 mirror maker

2022-02-10 Thread GitBox
mimaison commented on pull request #8862: URL: https://github.com/apache/kafka/pull/8862#issuecomment-1035132930 This PR is stalled so I'll close it out for now. Feel free to reopen if you want to restart working on it. -- This is an automated message from the Apache Git Service. To resp

[GitHub] [kafka] mimaison commented on pull request #8930: Mirror Maker 2: offset-syncs variable

2022-02-10 Thread GitBox
mimaison commented on pull request #8930: URL: https://github.com/apache/kafka/pull/8930#issuecomment-1035136857 I believe this has been addressed by [KIP-690](https://cwiki.apache.org/confluence/display/KAFKA/KIP-690%3A+Add+additional+configuration+to+control+MirrorMaker+2+internal+topics+

[GitHub] [kafka] mimaison closed pull request #8930: Mirror Maker 2: offset-syncs variable

2022-02-10 Thread GitBox
mimaison closed pull request #8930: URL: https://github.com/apache/kafka/pull/8930 -- 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..

[GitHub] [kafka] dajac commented on pull request #11742: KAFKA-13636: Fix for the group coordinator issue where the offsets are deleted for unstable groups

2022-02-10 Thread GitBox
dajac commented on pull request #11742: URL: https://github.com/apache/kafka/pull/11742#issuecomment-1035138963 Merged to trunk, 3.1, 3.0 and 2.8. -- 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

[jira] [Resolved] (KAFKA-13636) Committed offsets could be deleted during a rebalance if a group did not commit for a while

2022-02-10 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-13636. - Fix Version/s: 3.0.1 2.8.2 3.2.0 3.1.1

[GitHub] [kafka] artemlivshits commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
artemlivshits commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r803873160 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java ## @@ -211,7 +211,13 @@ protected v

[GitHub] [kafka] mimaison commented on pull request #4289: KAFKA-6301 changing regular expression in ops.html from '*' to '.*'

2022-02-10 Thread GitBox
mimaison commented on pull request #4289: URL: https://github.com/apache/kafka/pull/4289#issuecomment-1035142329 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [kafka] mimaison closed pull request #4289: KAFKA-6301 changing regular expression in ops.html from '*' to '.*'

2022-02-10 Thread GitBox
mimaison closed pull request #4289: URL: https://github.com/apache/kafka/pull/4289 -- 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..

[GitHub] [kafka] mimaison closed pull request #3899: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison closed pull request #3899: URL: https://github.com/apache/kafka/pull/3899 -- 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..

[GitHub] [kafka] mimaison commented on pull request #3899: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison commented on pull request #3899: URL: https://github.com/apache/kafka/pull/3899#issuecomment-1035147071 Since this PR was for the 0.10 docs, I think it can now be closed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [kafka] mimaison commented on pull request #3898: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison commented on pull request #3898: URL: https://github.com/apache/kafka/pull/3898#issuecomment-1035147300 Since this PR was for the 0.9 docs, I think it can now be closed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [kafka] mimaison closed pull request #3898: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison closed pull request #3898: URL: https://github.com/apache/kafka/pull/3898 -- 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..

[GitHub] [kafka] mimaison closed pull request #4281: [WIP] KAFKA-5693 rationalise policy interfaces

2022-02-10 Thread GitBox
mimaison closed pull request #4281: URL: https://github.com/apache/kafka/pull/4281 -- 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..

[GitHub] [kafka] mimaison commented on pull request #4281: [WIP] KAFKA-5693 rationalise policy interfaces

2022-02-10 Thread GitBox
mimaison commented on pull request #4281: URL: https://github.com/apache/kafka/pull/4281#issuecomment-1035154386 Since KIP-201 has been abandoned, I'm closing out this PR for now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [kafka] OneCricketeer commented on a change in pull request #11746: MINOR: Use timeout config in KafkaAdminClient

2022-02-10 Thread GitBox
OneCricketeer commented on a change in pull request #11746: URL: https://github.com/apache/kafka/pull/11746#discussion_r803897385 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java ## @@ -524,7 +524,7 @@ static KafkaAdminClient createInter

[GitHub] [kafka] mimaison commented on pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

2022-02-10 Thread GitBox
mimaison commented on pull request #11565: URL: https://github.com/apache/kafka/pull/11565#issuecomment-1035183468 Thanks @akatona84 for the PR. In order to add new configurations, we need to have a [KIP](https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals) --

[GitHub] [kafka] seanli-rallyhealth commented on a change in pull request #10265: [KAFKA-7718] KIP-634 implementation

2022-02-10 Thread GitBox
seanli-rallyhealth commented on a change in pull request #10265: URL: https://github.com/apache/kafka/pull/10265#discussion_r803917746 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/RecordValue.java ## @@ -34,6 +34,22 @@ final long timestamp; fi

[GitHub] [kafka] akatona84 commented on pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

2022-02-10 Thread GitBox
akatona84 commented on pull request #11565: URL: https://github.com/apache/kafka/pull/11565#issuecomment-1035198133 > Thanks @akatona84 for the PR. In order to add new configurations, we need to have a [KIP](https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals)

[GitHub] [kafka] mimaison commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
mimaison commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r803938280 ## File path: shell/src/test/java/org/apache/kafka/shell/MetadataNodeManagerTest.java ## @@ -290,4 +293,47 @@ public void testClientQuotaRecord() {

[GitHub] [kafka] hachikuji merged pull request #11546: Fix storage metadata comparison in storage tool

2022-02-10 Thread GitBox
hachikuji merged pull request #11546: URL: https://github.com/apache/kafka/pull/11546 -- 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-unsubsc

[jira] [Commented] (KAFKA-12635) Mirrormaker 2 offset sync is incorrect if the target partition is empty

2022-02-10 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490408#comment-17490408 ] Mickael Maison commented on KAFKA-12635: Thinking about this further, one thing

[GitHub] [kafka] hachikuji commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r804018735 ## File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java ## @@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordTy

[GitHub] [kafka] hachikuji commented on pull request #11558: KAFKA-13323 Fixed variable name in KafkaConsumer

2022-02-10 Thread GitBox
hachikuji commented on pull request #11558: URL: https://github.com/apache/kafka/pull/11558#issuecomment-1035409532 I went ahead and reverted the unrelated change in `docs/streams/developer-guide/processor-api.html` so that we can get the easy name fix checked in. -- This is an automate

[GitHub] [kafka] mjsax commented on pull request #11424: KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-02-10 Thread GitBox
mjsax commented on pull request #11424: URL: https://github.com/apache/kafka/pull/11424#issuecomment-1035421559 @vamossagar12 -- Any update from your side about opening a new PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [kafka] mumrah commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
mumrah commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r804057789 ## File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java ## @@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordType

[GitHub] [kafka] hachikuji opened a new pull request #11747: MINOR: Clearer field names for ProducerIdsRecord and related classes

2022-02-10 Thread GitBox
hachikuji opened a new pull request #11747: URL: https://github.com/apache/kafka/pull/11747 I found the current naming of the fields a little confusing in regard to whether the block range was inclusive or exclusive. This patch tries to improve naming to make this clearer. ### Commi

[GitHub] [kafka] hachikuji merged pull request #11655: KAFKA-13316; Enable KRaft mode in CreateTopics tests

2022-02-10 Thread GitBox
hachikuji merged pull request #11655: URL: https://github.com/apache/kafka/pull/11655 -- 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-unsubsc

[jira] [Resolved] (KAFKA-13316) Convert CreateTopicsRequestWithPolicyTest to use ClusterTest

2022-02-10 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13316. - Fix Version/s: 3.2.0 Assignee: dengziming Resolution: Fixed > Convert Cr

[GitHub] [kafka] hachikuji merged pull request #11558: KAFKA-13323 Fixed variable name in KafkaConsumer

2022-02-10 Thread GitBox
hachikuji merged pull request #11558: URL: https://github.com/apache/kafka/pull/11558 -- 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-unsubsc

[jira] [Resolved] (KAFKA-13323) The words are ambiguous

2022-02-10 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13323. - Fix Version/s: 3.2.0 Resolution: Fixed > The words are ambiguous > --

[GitHub] [kafka] hachikuji commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r804172617 ## File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java ## @@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordTy

[GitHub] [kafka] hachikuji commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r804247861 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java ## @@ -211,7 +211,13 @@ protected void

[GitHub] [kafka] hachikuji commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r804248978 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -699,11 +702,15 @@ public void handle(Jo

[jira] [Assigned] (KAFKA-13229) KIP-761: implement a total blocked time metric in Kafka Streams

2022-02-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13229: --- Assignee: Rohan Desai > KIP-761: implement a total blocked time metric in Kafka Str

[GitHub] [kafka] artemlivshits commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
artemlivshits commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r804264986 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java ## @@ -211,7 +211,13 @@ protected v

[GitHub] [kafka] hachikuji commented on a change in pull request #11667: MINOR; Enable Kraft in ApiVersionTest

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11667: URL: https://github.com/apache/kafka/pull/11667#discussion_r804266771 ## File path: core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala ## @@ -59,15 +68,40 @@ abstract class AbstractApiVersionsReque

[GitHub] [kafka] hachikuji commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r804270026 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket Se

[GitHub] [kafka] mdedetrich commented on pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-02-10 Thread GitBox
mdedetrich commented on pull request #11478: URL: https://github.com/apache/kafka/pull/11478#issuecomment-1035687499 I have rebased the PR against the latest Kafka trunk -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [kafka] junrao commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

2022-02-10 Thread GitBox
junrao commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r804020896 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -90,18 +90,42 @@ abstract class AbstractFetcherThread(name: String, p

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490612#comment-17490612 ] RivenSun commented on KAFKA-13663: -- [~lukebooxnote] Thank you for your reply I agree wi

[jira] [Commented] (KAFKA-13463) Improvement: KafkaConsumer pause(Collection partitions)

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490615#comment-17490615 ] RivenSun commented on KAFKA-13463: -- [~ableegoldman]  [~guozhang] [~showuon] [~lukebooxn

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490616#comment-17490616 ] Ismael Juma commented on KAFKA-13663: - Can you please try with the latest version of

[jira] [Commented] (KAFKA-13576) Processor.ConnectionQueueSize provides configuration & metrics, SelectorMetrics adds connection-register related metrics

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490617#comment-17490617 ] RivenSun commented on KAFKA-13576: -- Hi [~rsivaram]  [~ijuma] , [~guozhang]  can you gi

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490620#comment-17490620 ] RivenSun commented on KAFKA-13663: -- [~ijuma]  Thank you for your reply Upgrading the JD

[GitHub] [kafka] vamossagar12 closed pull request #10798: KAFKA-9168: Adding direct byte buffer support to rocksdb state store

2022-02-10 Thread GitBox
vamossagar12 closed pull request #10798: URL: https://github.com/apache/kafka/pull/10798 -- 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-unsu

[jira] [Resolved] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

2022-02-10 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao resolved KAFKA-9168. -- Resolution: Later This would be taken up once we have a more complete solution > Integrate JNI direct

[GitHub] [kafka] vamossagar12 commented on pull request #10798: KAFKA-9168: Adding direct byte buffer support to rocksdb state store

2022-02-10 Thread GitBox
vamossagar12 commented on pull request #10798: URL: https://github.com/apache/kafka/pull/10798#issuecomment-1035710408 @cadonna , done. -- 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 specif

[jira] [Commented] (KAFKA-13422) Even if the correct username and password are configured, when ClientBroker or KafkaClient tries to establish a SASL connection to ServerBroker, an exception is thrown

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490622#comment-17490622 ] RivenSun commented on KAFKA-13422: -- [~guozhang] Thank you for your reply [~rsivaram]  

[GitHub] [kafka] vamossagar12 commented on pull request #11424: KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-02-10 Thread GitBox
vamossagar12 commented on pull request #11424: URL: https://github.com/apache/kafka/pull/11424#issuecomment-1035710771 @mjsax not yet.. I couldn't find the time yet to pick this up. Would send an update soon. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [kafka] vamossagar12 commented on pull request #11433: KAFKA-13295: Avoiding Transation timeouts arising due to long restora…

2022-02-10 Thread GitBox
vamossagar12 commented on pull request #11433: URL: https://github.com/apache/kafka/pull/11433#issuecomment-1035711101 @ableegoldman . do you think this one is in a good shape? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

  1   2   >