[jira] [Commented] (KAFKA-13051) Require Principal Serde to be defined for 3.0

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377792#comment-17377792 ] Konstantine Karantasis commented on KAFKA-13051: [~rdielhenn] judging from the title I'm

[jira] [Updated] (KAFKA-13051) Require Principal Serde to be defined for 3.0

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-13051: --- Fix Version/s: 3.0.0 > Require Principal Serde to be defined for 3.0 >

[jira] [Commented] (KAFKA-12487) Sink connectors do not work with the cooperative consumer rebalance protocol

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377785#comment-17377785 ] Konstantine Karantasis commented on KAFKA-12487: Just a note that for tickets that need

[jira] [Updated] (KAFKA-12487) Sink connectors do not work with the cooperative consumer rebalance protocol

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12487: --- Fix Version/s: 3.0.0 > Sink connectors do not work with the cooperative

[jira] [Updated] (KAFKA-12487) Sink connectors do not work with the cooperative consumer rebalance protocol

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12487: --- Priority: Blocker (was: Major) > Sink connectors do not work with the

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1739#comment-1739 ] Konstantine Karantasis commented on KAFKA-4327: --- Based on your last comment [~mjsax] I've

[jira] [Updated] (KAFKA-4327) Move Reset Tool from core to streams

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-4327: -- Fix Version/s: (was: 3.0.0) 4.0.0 > Move Reset Tool

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1738#comment-1738 ] Konstantine Karantasis commented on KAFKA-9295: --- Thanks for the update [~ableegoldman].

[jira] [Updated] (KAFKA-13008) Stream will stop processing data for a long time while waiting for the partition lag

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-13008: --- Fix Version/s: 3.0.0 > Stream will stop processing data for a long time

[jira] [Updated] (KAFKA-13008) Stream will stop processing data for a long time while waiting for the partition lag

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-13008: --- Priority: Blocker (was: Major) > Stream will stop processing data for a

[jira] [Commented] (KAFKA-10714) Save unnecessary end txn call when the transaction is confirmed to be done

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1735#comment-1735 ] Konstantine Karantasis commented on KAFKA-10714: [~bchen225242] the parent issue targets

[jira] [Commented] (KAFKA-12493) The controller should handle the consistency between the controllerContext and the partition replicas assignment on zookeeper

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732 ] Konstantine Karantasis commented on KAFKA-12493: [~wenbing.shen] [~junrao] is this issue

[jira] [Updated] (KAFKA-12176) Consider changing default log.message.timestamp.difference.max.ms

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12176: --- Fix Version/s: (was: 3.0.0) 3.1.0 > Consider

[jira] [Commented] (KAFKA-12176) Consider changing default log.message.timestamp.difference.max.ms

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1731#comment-1731 ] Konstantine Karantasis commented on KAFKA-12176: [~hachikuji] [~junrao] I don't see any

[jira] [Commented] (KAFKA-7435) Consider standardizing the config object pattern on interface/implementation.

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377768#comment-17377768 ] Konstantine Karantasis commented on KAFKA-7435: --- [~vvcephei] [~guozhang] this feature

[jira] [Updated] (KAFKA-7435) Consider standardizing the config object pattern on interface/implementation.

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-7435: -- Fix Version/s: (was: 3.0.0) 3.1.0 > Consider

[jira] [Commented] (KAFKA-10675) Error message from ConnectSchema.validateValue() should include the name of the schema.

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377765#comment-17377765 ] Konstantine Karantasis commented on KAFKA-10675: [~iskuskov] [~rhauch] left a comment on

[GitHub] [kafka] kkonstantine commented on pull request #9541: KAFKA-10675: Add schema name to ConnectSchema.validateValue() error message

2021-07-08 Thread GitBox
kkonstantine commented on pull request #9541: URL: https://github.com/apache/kafka/pull/9541#issuecomment-876887351 @rhauch seems that this fix was approved but we were blocked on release candidates of previous releases. To include to 3.0 (as well as previous releases) and avoid entering

[GitHub] [kafka] kkonstantine commented on pull request #10827: [WIP] KAFKA-12899: Support --bootstrap-server in ReplicaVerificationTool

2021-07-08 Thread GitBox
kkonstantine commented on pull request #10827: URL: https://github.com/apache/kafka/pull/10827#issuecomment-876886212 @dongjinleekr @tombentley if we intend to include this fix to 3.0 we'll need to merge asap. Please let me know so I can update the status of

[jira] [Commented] (KAFKA-12774) kafka-streams 2.8: logging in uncaught-exceptionhandler doesn't go through log4j

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377754#comment-17377754 ] Konstantine Karantasis commented on KAFKA-12774: Code freeze for 3.0 is in just a few

[jira] [Resolved] (KAFKA-12686) Race condition in AlterIsr response handling

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-12686. Resolution: Fixed > Race condition in AlterIsr response handling >

[jira] [Commented] (KAFKA-12781) Improve the endOffsets accuracy in TaskMetadata

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377752#comment-17377752 ] Konstantine Karantasis commented on KAFKA-12781: [~ableegoldman] [~wcarlson5] we have

[jira] [Updated] (KAFKA-12781) Improve the endOffsets accuracy in TaskMetadata

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12781: --- Fix Version/s: (was: 3.0.0) 3.1.0 > Improve the

[jira] [Updated] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12766: --- Fix Version/s: (was: 3.0.0) 3.1.0 > Consider

[jira] [Commented] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377751#comment-17377751 ] Konstantine Karantasis commented on KAFKA-12766: We are past feature freeze for 3.0 and

[jira] [Commented] (KAFKA-12699) Streams no longer overrides the java default uncaught exception handler

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377748#comment-17377748 ] Konstantine Karantasis commented on KAFKA-12699: [~ableegoldman] [~wcarlson5] is this

[jira] [Commented] (KAFKA-10233) KafkaConsumer polls in a tight loop if group is not authorized

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377746#comment-17377746 ] Konstantine Karantasis commented on KAFKA-10233: The PR didn't get any updates for a

[jira] [Updated] (KAFKA-10233) KafkaConsumer polls in a tight loop if group is not authorized

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10233: --- Fix Version/s: (was: 3.0.0) 3.1.0 > KafkaConsumer

[jira] [Resolved] (KAFKA-12884) Remove "--zookeeper" in system tests

2021-07-08 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-12884. --- Resolution: Done > Remove "--zookeeper" in system tests > > >

[jira] [Updated] (KAFKA-7025) Android client support

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-7025: -- Fix Version/s: (was: 3.0.0) 3.1.0 > Android client

[jira] [Commented] (KAFKA-7025) Android client support

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377744#comment-17377744 ] Konstantine Karantasis commented on KAFKA-7025: --- I see this issue is still open but we are

[jira] [Commented] (KAFKA-12884) Remove "--zookeeper" in system tests

2021-07-08 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377745#comment-17377745 ] Luke Chen commented on KAFKA-12884: --- [~kkonstantine], thanks to [~rndgstn] , this is fixed in this PR: 

[jira] [Updated] (KAFKA-12622) Automate LICENSE file validation

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12622: --- Summary: Automate LICENSE file validation (was: Automate LICENCSE file

[jira] [Resolved] (KAFKA-12792) Fix metrics bug and introduce TimelineInteger

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-12792. Resolution: Fixed > Fix metrics bug and introduce TimelineInteger >

[jira] [Commented] (KAFKA-9910) Implement new transaction timed out error

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377741#comment-17377741 ] Konstantine Karantasis commented on KAFKA-9910: --- [~bchen225242] / [~zhaohaidao] similar

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

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377738#comment-17377738 ] Konstantine Karantasis commented on KAFKA-10588: The parent issue targets 3.0.0 and this

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

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10589: --- Priority: Blocker (was: Major) > Rename kafka-replica-verification CLI

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

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10589: --- Fix Version/s: 3.0.0 > Rename kafka-replica-verification CLI command line

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

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377739#comment-17377739 ] Konstantine Karantasis commented on KAFKA-10589: [~omnia_h_ibrahim] the parent issue

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

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10588: --- Priority: Blocker (was: Major) > Rename kafka-console-consumer CLI command

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

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10588: --- Fix Version/s: 3.0.0 > Rename kafka-console-consumer CLI command line

[jira] [Updated] (KAFKA-10587) Rename kafka-mirror-maker CLI command line arguments for KIP-629

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10587: --- Fix Version/s: 3.0.0 > Rename kafka-mirror-maker CLI command line arguments

[jira] [Resolved] (KAFKA-10587) Rename kafka-mirror-maker CLI command line arguments for KIP-629

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-10587. Resolution: Fixed > Rename kafka-mirror-maker CLI command line arguments

[jira] [Commented] (KAFKA-12886) Enable request forwarding by default in 3.0

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377735#comment-17377735 ] Konstantine Karantasis commented on KAFKA-12886: [~rdielhenn] is this improvement still

[GitHub] [kafka] cmccabe commented on pull request #10997: MINOR: Fix flaky deleteSnapshots test

2021-07-08 Thread GitBox
cmccabe commented on pull request #10997: URL: https://github.com/apache/kafka/pull/10997#issuecomment-876822894 Committed to trunk and 3.0 -- 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] cmccabe closed pull request #10997: MINOR: Fix flaky deleteSnapshots test

2021-07-08 Thread GitBox
cmccabe closed pull request #10997: URL: https://github.com/apache/kafka/pull/10997 -- 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 #10991: MINOR: system test fix for 3 co-located KRaft controllers

2021-07-08 Thread GitBox
cmccabe commented on pull request #10991: URL: https://github.com/apache/kafka/pull/10991#issuecomment-876822385 > That's a good idea. I think the diff above has a problem in that we would emit the message too early for the case where process.roles=broker, but I think the idea in general

[GitHub] [kafka] jsancio opened a new pull request #11005: MINOR: Print the cached broker epoch

2021-07-08 Thread GitBox
jsancio opened a new pull request #11005: URL: https://github.com/apache/kafka/pull/11005 When the broker epochs do not match make sure to print both broker epochs. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify

[GitHub] [kafka] cmccabe commented on a change in pull request #10997: MINOR: Fix flaky deleteSnapshots test

2021-07-08 Thread GitBox
cmccabe commented on a change in pull request #10997: URL: https://github.com/apache/kafka/pull/10997#discussion_r666583174 ## File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala ## @@ -404,13 +404,13 @@ final class KafkaMetadataLog private ( return false

[jira] [Comment Edited] (KAFKA-13008) Stream will stop processing data for a long time while waiting for the partition lag

2021-07-08 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377644#comment-17377644 ] Colin McCabe edited comment on KAFKA-13008 at 7/8/21, 11:42 PM: Thanks,

[jira] [Commented] (KAFKA-13008) Stream will stop processing data for a long time while waiting for the partition lag

2021-07-08 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377644#comment-17377644 ] Colin McCabe commented on KAFKA-13008: -- > Surely if a partition was removed from the assignment and

[jira] [Comment Edited] (KAFKA-13008) Stream will stop processing data for a long time while waiting for the partition lag

2021-07-08 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377644#comment-17377644 ] Colin McCabe edited comment on KAFKA-13008 at 7/8/21, 11:41 PM: bq.

[GitHub] [kafka] xvrl commented on pull request #9404: KAFKA-10589 replica verification tool changes for KIP-629

2021-07-08 Thread GitBox
xvrl commented on pull request #9404: URL: https://github.com/apache/kafka/pull/9404#issuecomment-876810546 Hi @dongjinleekr, I believe @OmniaGM is taking care of this already, so I'll close this out. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [kafka] xvrl closed pull request #9404: KAFKA-10589 replica verification tool changes for KIP-629

2021-07-08 Thread GitBox
xvrl closed pull request #9404: URL: https://github.com/apache/kafka/pull/9404 -- 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] [Commented] (KAFKA-12477) Smart rebalancing with dynamic protocol selection

2021-07-08 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377635#comment-17377635 ] A. Sophie Blee-Goldman commented on KAFKA-12477: No, we already decided to postpone this

[jira] [Updated] (KAFKA-12477) Smart rebalancing with dynamic protocol selection

2021-07-08 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12477: --- Fix Version/s: (was: 3.0.0) 3.1.0 > Smart

[jira] [Commented] (KAFKA-12884) Remove "--zookeeper" in system tests

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377634#comment-17377634 ] Konstantine Karantasis commented on KAFKA-12884: [~showuon] will this make it for 3.0 ?

[jira] [Updated] (KAFKA-12884) Remove "--zookeeper" in system tests

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12884: --- Priority: Blocker (was: Major) > Remove "--zookeeper" in system tests >

[jira] [Updated] (KAFKA-12884) Remove "--zookeeper" in system tests

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12884: --- Fix Version/s: 3.0.0 > Remove "--zookeeper" in system tests >

[jira] [Updated] (KAFKA-12588) Remove deprecated --zookeeper in shell commands

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12588: --- Priority: Blocker (was: Major) > Remove deprecated --zookeeper in shell

[jira] [Commented] (KAFKA-10091) Improve task idling

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377633#comment-17377633 ] Konstantine Karantasis commented on KAFKA-10091: [~vvcephei] confirmed offline that we

[jira] [Commented] (KAFKA-7632) Support Compression Level

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377632#comment-17377632 ] Konstantine Karantasis commented on KAFKA-7632: --- The PR was rebased by [~dongjin]. Marking

[jira] [Updated] (KAFKA-7632) Support Compression Level

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-7632: -- Priority: Blocker (was: Major) > Support Compression Level >

[jira] [Updated] (KAFKA-10091) Improve task idling

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10091: --- Priority: Blocker (was: Major) > Improve task idling > ---

[jira] [Resolved] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-10292. Resolution: Fixed > fix flaky streams/streams_broker_bounce_test.py >

[jira] [Commented] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377631#comment-17377631 ] Konstantine Karantasis commented on KAFKA-10292: PR has been merged in time for 3.0. Not

[jira] [Updated] (KAFKA-5905) Remove PrincipalBuilder and DefaultPrincipalBuilder

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-5905: -- Priority: Blocker (was: Major) > Remove PrincipalBuilder and

[jira] [Commented] (KAFKA-5905) Remove PrincipalBuilder and DefaultPrincipalBuilder

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377629#comment-17377629 ] Konstantine Karantasis commented on KAFKA-5905: --- [~omkreddy] [~hachikuji] [~ijuma] if this

[jira] [Commented] (KAFKA-12477) Smart rebalancing with dynamic protocol selection

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377622#comment-17377622 ] Konstantine Karantasis commented on KAFKA-12477: [~ableegoldman] [~guozhang]  is this

[jira] [Commented] (KAFKA-10345) Add auto reloading for trust/key store paths

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377621#comment-17377621 ] Konstantine Karantasis commented on KAFKA-10345: [~ableegoldman] [~guozhang] is this

[jira] [Commented] (KAFKA-9705) Zookeeper mutation protocols should be redirected to Controller only

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377620#comment-17377620 ] Konstantine Karantasis commented on KAFKA-9705: --- cc [~bchen225242] > Zookeeper mutation

[jira] [Commented] (KAFKA-9705) Zookeeper mutation protocols should be redirected to Controller only

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377619#comment-17377619 ] Konstantine Karantasis commented on KAFKA-9705: --- [~cmccabe] do you mind confirming if all

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

2021-07-08 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377616#comment-17377616 ] A. Sophie Blee-Goldman commented on KAFKA-9295: --- [~kkonstantine] Luke was able to figure

[jira] [Updated] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9295: -- Priority: Blocker (was: Critical) >

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377614#comment-17377614 ] Konstantine Karantasis commented on KAFKA-9295: --- I see it's a flaky test (missed this

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377613#comment-17377613 ] Konstantine Karantasis commented on KAFKA-9295: --- [~showuon] [~ableegoldman] is this

[jira] [Commented] (KAFKA-12598) Remove deprecated --zookeeper in ConfigCommand

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377612#comment-17377612 ] Konstantine Karantasis commented on KAFKA-12598: Marking this issue as Blocker and

[jira] [Updated] (KAFKA-12598) Remove deprecated --zookeeper in ConfigCommand

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12598: --- Priority: Blocker (was: Critical) > Remove deprecated --zookeeper in

[GitHub] [kafka] vvcephei commented on pull request #10661: MINOR: upgrade pip from 20.2.2 to 21.1.1

2021-07-08 Thread GitBox
vvcephei commented on pull request #10661: URL: https://github.com/apache/kafka/pull/10661#issuecomment-876783256 Ah, and now I noticed that we've added a message to this effect in the script today: https://github.com/apache/kafka/pull/10995 Carry on :) -- This is an automated

[GitHub] [kafka] vvcephei commented on pull request #10661: MINOR: upgrade pip from 20.2.2 to 21.1.1

2021-07-08 Thread GitBox
vvcephei commented on pull request #10661: URL: https://github.com/apache/kafka/pull/10661#issuecomment-876782447 Hmm, I also hit that same error today. It seems to have been caused because the image was running Debian 9, and the latest version of `python3` available in Debian 9 is

[GitHub] [kafka] kkonstantine commented on pull request #10826: KAFKA-7632: Support Compression Level

2021-07-08 Thread GitBox
kkonstantine commented on pull request #10826: URL: https://github.com/apache/kafka/pull/10826#issuecomment-876779515 @tombentley do you think you'll be able to finish the review soon? If we had an approval I'd be willing to make an exception and consider this feature for inclusion to AK

[jira] [Commented] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377611#comment-17377611 ] Konstantine Karantasis commented on KAFKA-10733: Thanks for the update [~bchen225242].

[jira] [Updated] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10733: --- Fix Version/s: (was: 3.0.0) 3.1.0 > Enforce

[GitHub] [kafka] emveee edited a comment on pull request #7898: KAFKA-9366: Change log4j dependency into log4j2

2021-07-08 Thread GitBox
emveee edited a comment on pull request #7898: URL: https://github.com/apache/kafka/pull/7898#issuecomment-876773034 > @priyavj08 I'm sorry that I can't be certain. But as far as I know, any project with log4j 1.2.7 is not safe. (It is why I have been working on this issue.) > >

[jira] [Updated] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6718: -- Fix Version/s: (was: 3.0.0) 3.1.0 > Rack Aware Stand-by

[GitHub] [kafka] emveee commented on pull request #7898: KAFKA-9366: Change log4j dependency into log4j2

2021-07-08 Thread GitBox
emveee commented on pull request #7898: URL: https://github.com/apache/kafka/pull/7898#issuecomment-876773034 > @priyavj08 I'm sorry that I can't be certain. But as far as I know, any project with log4j 1.2.7 is not safe. (It is why I have been working on this issue.) > > +1. I

[jira] [Commented] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377607#comment-17377607 ] Konstantine Karantasis commented on KAFKA-6718: --- The main PR for this feature hasn't been

[jira] [Closed] (KAFKA-12362) Determine if a Task is idling

2021-07-08 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis closed KAFKA-12362. -- > Determine if a Task is idling > - > >

[jira] [Comment Edited] (KAFKA-13054) Unexpected Polling Behavior

2021-07-08 Thread Gary Russell (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377606#comment-17377606 ] Gary Russell edited comment on KAFKA-13054 at 7/8/21, 9:55 PM: --- Yes, after

[jira] [Commented] (KAFKA-13054) Unexpected Polling Behavior

2021-07-08 Thread Gary Russell (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377606#comment-17377606 ] Gary Russell commented on KAFKA-13054: -- Yes, after increasing the partitions, I get 2000 on each

[jira] [Commented] (KAFKA-13054) Unexpected Polling Behavior

2021-07-08 Thread Gary Russell (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377600#comment-17377600 ] Gary Russell commented on KAFKA-13054: -- I think I see a pattern; the 3rd poll does not fetch any

[GitHub] [kafka] vvcephei edited a comment on pull request #10602: KAFKA-12724: Add 2.8.0 to system tests and streams upgrade tests.

2021-07-08 Thread GitBox
vvcephei edited a comment on pull request #10602: URL: https://github.com/apache/kafka/pull/10602#issuecomment-876765383 I haven't verified it, but I think your problem is that you needed to do `./gradlew clean systemTestLibs` instead of `:streams:testAll`. -- This is an automated

[GitHub] [kafka] vvcephei commented on pull request #10602: KAFKA-12724: Add 2.8.0 to system tests and streams upgrade tests.

2021-07-08 Thread GitBox
vvcephei commented on pull request #10602: URL: https://github.com/apache/kafka/pull/10602#issuecomment-876765383 Hmm, I had some trouble with the required pip version... I went ahead and kicked off: I haven't verified it, but I think your problem is that you needed to do

[GitHub] [kafka] jolshan commented on a change in pull request #11004: KAFKA-12257: Consumer mishandles topics deleted and recreated with the same name (trunk)

2021-07-08 Thread GitBox
jolshan commented on a change in pull request #11004: URL: https://github.com/apache/kafka/pull/11004#discussion_r666535365 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java ## @@ -1206,7 +1205,8 @@ private void

[GitHub] [kafka] jolshan opened a new pull request #11004: KAFKA-12257: Consumer mishandles topics deleted and recreated with the same name (trunk)

2021-07-08 Thread GitBox
jolshan opened a new pull request #11004: URL: https://github.com/apache/kafka/pull/11004 Trunk version of https://github.com/apache/kafka/pull/10952 This PR slightly cleans up some of the changes made in https://github.com/apache/kafka/pull/9944 Store topic ID info in

[jira] [Created] (KAFKA-13054) Unexpected Polling Behavior

2021-07-08 Thread Gary Russell (Jira)
Gary Russell created KAFKA-13054: Summary: Unexpected Polling Behavior Key: KAFKA-13054 URL: https://issues.apache.org/jira/browse/KAFKA-13054 Project: Kafka Issue Type: Improvement

[GitHub] [kafka] vvcephei commented on pull request #10602: KAFKA-12724: Add 2.8.0 to system tests and streams upgrade tests.

2021-07-08 Thread GitBox
vvcephei commented on pull request #10602: URL: https://github.com/apache/kafka/pull/10602#issuecomment-876758534 Hmm, I had some trouble with the required pip version... I went ahead and kicked off https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4586/ while I debug my

[GitHub] [kafka] vvcephei commented on pull request #10602: KAFKA-12724: Add 2.8.0 to system tests and streams upgrade tests.

2021-07-08 Thread GitBox
vvcephei commented on pull request #10602: URL: https://github.com/apache/kafka/pull/10602#issuecomment-876748402 Thanks, @kamalcph ! I'll take a look 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

[GitHub] [kafka] vvcephei commented on pull request #11003: KAFKA-12360: Document new time semantics

2021-07-08 Thread GitBox
vvcephei commented on pull request #11003: URL: https://github.com/apache/kafka/pull/11003#issuecomment-876743838 Thanks for the review, @JimGalasyn ! I've just reworded the main documentation section in response to your feedback. I also included a few other improvements I noticed on the

[jira] [Created] (KAFKA-13053) Bump frame version for KRaft records

2021-07-08 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-13053: --- Summary: Bump frame version for KRaft records Key: KAFKA-13053 URL: https://issues.apache.org/jira/browse/KAFKA-13053 Project: Kafka Issue Type: Bug

  1   2   3   >