JoeCqupt commented on pull request #11427:
URL: https://github.com/apache/kafka/pull/11427#issuecomment-952564114
Call for review @dajac
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434669#comment-17434669
]
Luke Chen commented on KAFKA-12984:
---
Yes, I'm going to create another Jira issue for i
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434666#comment-17434666
]
A. Sophie Blee-Goldman commented on KAFKA-12984:
[~showuon] want to prep
showuon commented on pull request #11413:
URL: https://github.com/apache/kafka/pull/11413#issuecomment-952499102
@UnityLung @chia7712 @rhauch , please help review this PR when available.
Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434645#comment-17434645
]
Luke Chen commented on KAFKA-13403:
---
[~arunmathew88], I can't, either. I think it's be
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-13403:
-
Assignee: Haruki Okada
> KafkaServer crashes when deleting topics due to the race in log deleti
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-13403:
-
Assignee: (was: Haruki Okada)
> KafkaServer crashes when deleting topics due to the race in
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434641#comment-17434641
]
Arun Mathew commented on KAFKA-13403:
-
Hello [~showuon], I am a colleague of [~ocada
arunmathew88 opened a new pull request #11438:
URL: https://github.com/apache/kafka/pull/11438
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of te
[
https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434635#comment-17434635
]
RivenSun commented on KAFKA-13398:
--
[~tombentley] Thank you for your suggestion, this
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada reassigned KAFKA-13403:
Assignee: Haruki Okada
> KafkaServer crashes when deleting topics due to the race in log
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada reassigned KAFKA-13403:
Assignee: (was: Haruki Okada)
> KafkaServer crashes when deleting topics due to the r
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434631#comment-17434631
]
Luke Chen commented on KAFKA-13403:
---
[~ocadaruma], go ahead to take over. I thought yo
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-13403:
-
Assignee: Haruki Okada (was: Luke Chen)
> KafkaServer crashes when deleting topics due to the
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434630#comment-17434630
]
Haruki Okada edited comment on KAFKA-13403 at 10/27/21, 1:49 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434630#comment-17434630
]
Haruki Okada commented on KAFKA-13403:
--
[~showuon] Already working on it? or may I.
ableegoldman commented on a change in pull request #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r737016054
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -280,6 +328,13 @@ public void handleAssignme
jolshan edited a comment on pull request #11331:
URL: https://github.com/apache/kafka/pull/11331#issuecomment-949274575
TODOs:
1. ~Change inconsistent topic ID so it is no longer a top level error~
2. ~Maybe refactor some of the receiving side code, we have a map with
TopicIdPartition
kirktrue commented on a change in pull request #11284:
URL: https://github.com/apache/kafka/pull/11284#discussion_r736971828
##
File path:
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/RefreshingHttpsJwks.java
##
@@ -0,0 +1,328 @@
+/*
+ * Licensed
kirktrue commented on a change in pull request #11284:
URL: https://github.com/apache/kafka/pull/11284#discussion_r736970385
##
File path:
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerValidatorCallbackHandler.java
##
@@ -0,0 +1,283 @@
+
kirktrue commented on a change in pull request #11284:
URL: https://github.com/apache/kafka/pull/11284#discussion_r736970042
##
File path:
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerValidatorCallbackHandler.java
##
@@ -0,0 +1,283 @@
+
kirktrue commented on a change in pull request #11284:
URL: https://github.com/apache/kafka/pull/11284#discussion_r736970042
##
File path:
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerValidatorCallbackHandler.java
##
@@ -0,0 +1,283 @@
+
kirktrue commented on a change in pull request #11284:
URL: https://github.com/apache/kafka/pull/11284#discussion_r736969618
##
File path:
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerValidatorCallbackHandler.java
##
@@ -0,0 +1,283 @@
+
cmccabe merged pull request #11437:
URL: https://github.com/apache/kafka/pull/11437
--
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.
cmccabe edited a comment on pull request #11417:
URL: https://github.com/apache/kafka/pull/11417#issuecomment-952366646
> The patch seems ok. I confess it's not obvious to me what this approach
buys us over the use of ClusterTestExtensions. Seems like another way we could
do this is to let
cmccabe commented on pull request #11417:
URL: https://github.com/apache/kafka/pull/11417#issuecomment-952366646
> The patch seems ok. I confess it's not obvious to me what this approach
buys us over the use of ClusterTestExtensions. Seems like another way we could
do this is to let Quorum
cmccabe commented on a change in pull request #11417:
URL: https://github.com/apache/kafka/pull/11417#discussion_r736953818
##
File path: core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala
##
@@ -0,0 +1,339 @@
+/**
+ * Licensed to the Apache Software Foundatio
cmccabe merged pull request #11028:
URL: https://github.com/apache/kafka/pull/11028
--
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.
cmccabe commented on pull request #11028:
URL: https://github.com/apache/kafka/pull/11028#issuecomment-952342421
Seems reasonable. Thanks, @tombentley .
--
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
cmccabe commented on pull request #10830:
URL: https://github.com/apache/kafka/pull/10830#issuecomment-952338663
I left a comment. LGTM aside from that.
Thanks, @dengziming .
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
cmccabe commented on a change in pull request #10830:
URL: https://github.com/apache/kafka/pull/10830#discussion_r736932247
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java
##
@@ -94,6 +94,15 @@ public static int jsonNodeToUnsignedShort(Jso
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434579#comment-17434579
]
A. Sophie Blee-Goldman commented on KAFKA-12984:
Mm, yeah, I should've r
cmccabe closed pull request #10956:
URL: https://github.com/apache/kafka/pull/10956
--
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.
cmccabe commented on pull request #10956:
URL: https://github.com/apache/kafka/pull/10956#issuecomment-952334166
committed
--
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.
guozhangwang commented on pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#issuecomment-952326762
I made another pass on the PR, LGTM. Also there are successful runs from
jenkins too. @mjsax please feel free to merge it after your final pass.
--
This is an automated m
hachikuji commented on a change in pull request #11437:
URL: https://github.com/apache/kafka/pull/11437#discussion_r736921796
##
File path:
shell/src/test/java/org/apache/kafka/shell/MetadataNodeManagerTest.java
##
@@ -264,16 +264,30 @@ public void testClientQuotaRecord() {
guozhangwang commented on a change in pull request #11368:
URL: https://github.com/apache/kafka/pull/11368#discussion_r736921585
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java
##
@@
[
https://issues.apache.org/jira/browse/KAFKA-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10800.
-
Resolution: Fixed
> Validate the snapshot id when the state machine creates a snapshot
>
hachikuji merged pull request #10593:
URL: https://github.com/apache/kafka/pull/10593
--
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
junrao commented on a change in pull request #11284:
URL: https://github.com/apache/kafka/pull/11284#discussion_r736894948
##
File path:
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/secured/OAuthBearerValidatorCallbackHandler.java
##
@@ -0,0 +1,283 @@
+/*
cmccabe edited a comment on pull request #11339:
URL: https://github.com/apache/kafka/pull/11339#issuecomment-952318773
I filed https://github.com/apache/kafka/pull/11437 to fix up the path that
we're using. These shouldn't actually be in the config directory (because
they're not configs)
cmccabe commented on pull request #11339:
URL: https://github.com/apache/kafka/pull/11339#issuecomment-952318773
I followed https://github.com/apache/kafka/pull/11437 to fix up the path
that we're using. These shouldn't actually be in the config directory (because
they're not configs)
--
ableegoldman opened a new pull request #11436:
URL: https://github.com/apache/kafka/pull/11436
Minor followup to [#11405](https://github.com/apache/kafka/pull/11405) /
[KIP-783](https://cwiki.apache.org/confluence/display/KAFKA/KIP-783%3A+Add+TaskId+field+to+StreamsException)
to write down
cmccabe commented on pull request #10956:
URL: https://github.com/apache/kafka/pull/10956#issuecomment-952310185
> ping @cmccabe , I'm also thinking about moving MetadataCache into
kafka.server.metadata , WDYT?
yes, this should be in the `kafka.server.metadata` package, consistent wi
cmccabe merged pull request #11339:
URL: https://github.com/apache/kafka/pull/11339
--
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.
cmccabe commented on pull request #11339:
URL: https://github.com/apache/kafka/pull/11339#issuecomment-952292489
I re-ran SaslPlainSslEndToEndAuthorizationTest and LeaderElectionCommandTest
locally and they both passed. These tests are known to be flaky and the failure
is not caused by thi
cmccabe commented on pull request #11339:
URL: https://github.com/apache/kafka/pull/11339#issuecomment-952276357
@dengziming : thanks for this! I'm sorry that I've been so slow to review
things lately... too much work piled up. I think it looks good. I especially
liked that you added `Meta
[
https://issues.apache.org/jira/browse/KAFKA-13368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434418#comment-17434418
]
Pedro Cardoso Silva edited comment on KAFKA-13368 at 10/26/21, 7:16 PM:
--
upsidedownsmile commented on pull request #11375:
URL: https://github.com/apache/kafka/pull/11375#issuecomment-952228333
@guozhangwang could you review 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
MasonLegere opened a new pull request #11435:
URL: https://github.com/apache/kafka/pull/11435
Implementation of proposed changes outlined in KIP 786.
- Optionally emits client quota values attached to the `byte-rate` and
`throttle-time` under the `kafka.server` MBean.
- This
[
https://issues.apache.org/jira/browse/KAFKA-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434516#comment-17434516
]
Guozhang Wang commented on KAFKA-13226:
---
Hello! It's a bit unfortunate that not ev
Daniel O'Halloran created KAFKA-13405:
-
Summary: Kafka Streams restore-consumer fails to refresh broker
IPs after upgrading Kafka cluster
Key: KAFKA-13405
URL: https://issues.apache.org/jira/browse/KAFKA-13405
[
https://issues.apache.org/jira/browse/KAFKA-13368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434418#comment-17434418
]
Pedro Cardoso Silva commented on KAFKA-13368:
-
Thank you for your suggestion
[
https://issues.apache.org/jira/browse/KAFKA-12334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434416#comment-17434416
]
Igor Soarez commented on KAFKA-12334:
-
[~cmccabe] I don't think this is "Resolved".
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434408#comment-17434408
]
Andrei D commented on KAFKA-12984:
--
[~showuon] Thank you for the fast and complete anal
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434389#comment-17434389
]
Luke Chen edited comment on KAFKA-12984 at 10/26/21, 2:11 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434389#comment-17434389
]
Luke Chen commented on KAFKA-12984:
---
[~Andy_Dufresne], thanks for the log. I have some
[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434385#comment-17434385
]
prabhu commented on KAFKA-13400:
here is the complete stack trace.
this should not happe
[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434378#comment-17434378
]
Gary Russell commented on KAFKA-13400:
--
While this does not appear to be related to
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434281#comment-17434281
]
Andrei D edited comment on KAFKA-12984 at 10/26/21, 1:23 PM:
-
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r736515669
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
soarez commented on pull request #9577:
URL: https://github.com/apache/kafka/pull/9577#issuecomment-951893322
@dengziming @mumrah now that 2.8 has been released, should this be rebased
and reviewed again?
--
This is an automated message from the Apache Git Service.
To respond to the mes
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r736487363
##
File path:
clients/src/test/java/org/apache/kafka/common/security/JaasContextTest.java
##
@@ -172,14 +172,42 @@ public void testMissingSemicolon(
bvn13 commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r736438767
##
File path:
clients/src/test/java/org/apache/kafka/common/security/JaasContextTest.java
##
@@ -172,14 +172,42 @@ public void testMissingSemicolon() throw
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434281#comment-17434281
]
Andrei D edited comment on KAFKA-12984 at 10/26/21, 11:15 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434281#comment-17434281
]
Andrei D commented on KAFKA-12984:
--
Here are debug logs.
The freeze happened at 15:48:2
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei D updated KAFKA-12984:
-
Attachment: logs-insights-results-kafka.csv
> Cooperative sticky assignor can get stuck with invalid Sub
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei D updated KAFKA-12984:
-
Comment: was deleted
(was: Here are debug logs.
The freeze happened at 15:48:23
[^log-events-viewer-re
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei D updated KAFKA-12984:
-
Attachment: log-events-viewer-result-kafka.numbers
> Cooperative sticky assignor can get stuck with inva
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei D updated KAFKA-12984:
-
Comment: was deleted
(was: Here are debug logs.
The freeze happened at 15:48:23
[^logs-insights-results
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434279#comment-17434279
]
Andrei D commented on KAFKA-12984:
--
Here are debug logs.
The freeze happened at 15:48:2
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434276#comment-17434276
]
Andrei D commented on KAFKA-12984:
--
Here are debug logs.
The freeze happened at 15:48:2
[
https://issues.apache.org/jira/browse/KAFKA-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrei D updated KAFKA-12984:
-
Attachment: logs-insights-results-kafka.numbers
> Cooperative sticky assignor can get stuck with invalid
[
https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu-Jhe Li updated KAFKA-13404:
--
Description:
The Kafka sink connectors don't commit offset to the latest log-end offset if
the messag
[
https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu-Jhe Li updated KAFKA-13404:
--
Attachment: Main.scala
> Kafka sink connectors do not commit offset correctly if messages are produced
[
https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu-Jhe Li updated KAFKA-13404:
--
Description:
The Kafka sink connectors don't commit offset to the latest log-end offset if
the messag
[
https://issues.apache.org/jira/browse/KAFKA-13404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu-Jhe Li updated KAFKA-13404:
--
Description:
The Kafka sink connectors don't commit offset to the latest log-end offset if
the messag
Yu-Jhe Li created KAFKA-13404:
-
Summary: Kafka sink connectors do not commit offset correctly if
messages are produced in transaction
Key: KAFKA-13404
URL: https://issues.apache.org/jira/browse/KAFKA-13404
dajac opened a new pull request #11434:
URL: https://github.com/apache/kafka/pull/11434
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade not
[
https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-13403:
-
Assignee: Luke Chen
> KafkaServer crashes when deleting topics due to the race in log deletion
[
https://issues.apache.org/jira/browse/KAFKA-13394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13394:
Priority: Blocker (was: Major)
> Topic IDs should be removed from PartitionFetchState if they are
[
https://issues.apache.org/jira/browse/KAFKA-13394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13394:
Fix Version/s: 3.1.0
> Topic IDs should be removed from PartitionFetchState if they are no longer
dongjinleekr commented on a change in pull request #11431:
URL: https://github.com/apache/kafka/pull/11431#discussion_r736291869
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
##
@@ -183,12 +187,18 @@ public MirrorClientConfig
[
https://issues.apache.org/jira/browse/KAFKA-13111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13111:
Fix Version/s: 3.1.0
> Re-evaluate Fetch Sessions when using topic IDs
> -
[
https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434195#comment-17434195
]
David Jacot commented on KAFKA-7632:
I was reduced the priority.
> Support Compressi
[
https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-7632:
---
Priority: Major (was: Blocker)
> Support Compression Level
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13111:
Priority: Blocker (was: Major)
> Re-evaluate Fetch Sessions when using topic IDs
> --
[
https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434185#comment-17434185
]
Tom Bentley commented on KAFKA-13398:
-
[~RivenSun] the Admin client is backwards com
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r736271082
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r736269591
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
dongjinleekr commented on a change in pull request #11431:
URL: https://github.com/apache/kafka/pull/11431#discussion_r736258242
##
File path:
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java
##
@@ -50,8 +50,7 @@
public static fi
dongjinleekr commented on a change in pull request #11430:
URL: https://github.com/apache/kafka/pull/11430#discussion_r736245197
##
File path:
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java
##
@@ -50,12 +50,24 @@
private final List configEntries;
[
https://issues.apache.org/jira/browse/KAFKA-13368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434154#comment-17434154
]
Luke Chen commented on KAFKA-13368:
---
[~pcless], thanks for the suggestion. I suggest y
93 matches
Mail list logo