[
https://issues.apache.org/jira/browse/KAFKA-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sunil updated KAFKA-13652:
--
Priority: Trivial (was: Minor)
> encrypt the passwords in kafka jaas conf file
>
ableegoldman opened a new pull request #11738:
URL: https://github.com/apache/kafka/pull/11738
Note: this is just part 1 of the error handling work, and is intended to lay
the groundwork for identifying and handling tasks that are unstable so that
they don't affect the ability of the other
RivenSun2 commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1032400190
Hi @guozhangwang
I pulled the latest code of apache:trunk and resolved the conflict.
Please help to check again,thanks.
--
This is an automated message from the Apach
cadonna commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-1032412988
@lkokhreidze I will try to review this Friday. Sorry for the delay but I was
sick for the last two weeks.
--
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/KAFKA-13293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488714#comment-17488714
]
Elliot West commented on KAFKA-13293:
-
[~rsivaram] ^
> Support client reload of JKS
[
https://issues.apache.org/jira/browse/KAFKA-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sunil updated KAFKA-13652:
--
Priority: Major (was: Trivial)
> encrypt the passwords in kafka jaas conf file
>
showuon commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1032436889
@RivenSun2 , I checked the build results after your rebase, there's a test
`ConsumerBounceTest.testClose` that failed twice with NPE. That looks
suspicious and didn't fail in `
showuon edited a comment on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1032436889
@RivenSun2 , I checked the build results after your rebase, there's a test
`ConsumerBounceTest.testClose` that failed twice with NPE. That looks
suspicious and didn't fa
showuon commented on pull request #5407:
URL: https://github.com/apache/kafka/pull/5407#issuecomment-1032446428
@stanislavkozlovski , I'm going to take over this ticket tomorrow if you
don't mind. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the m
stanislavkozlovski commented on pull request #5407:
URL: https://github.com/apache/kafka/pull/5407#issuecomment-1032569807
@showuon yes, please feel free. apologies for being slow to respond and
missing the previous messages about reviving this. I will go ahead and close
this PR now
--
stanislavkozlovski closed pull request #5407:
URL: https://github.com/apache/kafka/pull/5407
--
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-
showuon commented on pull request #5407:
URL: https://github.com/apache/kafka/pull/5407#issuecomment-1032580659
Thank you!
--
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.
Jorge Esteban Quilcate Otoya created KAFKA-13654:
Summary: Extend KStream process with new Processor API
Key: KAFKA-13654
URL: https://issues.apache.org/jira/browse/KAFKA-13654
Project:
ijuma opened a new pull request #11739:
URL: https://github.com/apache/kafka/pull/11739
Introduce `maxScalacThreads` and set the default to the lowest of `8`
and the number of processors available to the JVM. The number `8` was
picked empirically, the sweet spot is between 6 and 10.
michalxo opened a new pull request #11740:
URL: https://github.com/apache/kafka/pull/11740
Signed-off-by: Michal T
Simple typo in version in Dockerfile
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
Mario Mastrodicasa created KAFKA-13655:
--
Summary: Cannot edit clients page
Key: KAFKA-13655
URL: https://issues.apache.org/jira/browse/KAFKA-13655
Project: Kafka
Issue Type: Bug
satishd edited a comment on pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#issuecomment-1019966726
@junrao : Thanks for the review. Addressed your comments with the latest
commits.
Rebased with the trunk to resolve the conflicts.
--
This is an automated mess
soceanainn closed pull request #11482:
URL: https://github.com/apache/kafka/pull/11482
--
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-unsubs
soceanainn commented on pull request #11482:
URL: https://github.com/apache/kafka/pull/11482#issuecomment-1032743124
An equivalent change was implemented and merged in #11689
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
C0urante commented on pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#issuecomment-1032801881
Thanks Mikael, I can take a stab at that. I don't think I can get each PR to
be buildable on its own without a lot of work but I can definitely isolate
high-level sections int
mimaison merged pull request #11740:
URL: https://github.com/apache/kafka/pull/11740
--
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
ijuma opened a new pull request #11741:
URL: https://github.com/apache/kafka/pull/11741
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
Jorge Esteban Quilcate Otoya created KAFKA-13656:
Summary: Connect Transforms support for nested structures
Key: KAFKA-13656
URL: https://issues.apache.org/jira/browse/KAFKA-13656
Proje
[
https://issues.apache.org/jira/browse/KAFKA-13654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-13654:
-
Labels: kafka-streams kip-required needs-kip streams (was: kafka
[
https://issues.apache.org/jira/browse/KAFKA-3881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489067#comment-17489067
]
Andrey Polyakov commented on KAFKA-3881:
+1 to this ticket and David's PR.
We ha
[
https://issues.apache.org/jira/browse/KAFKA-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prince Mahajan reassigned KAFKA-13636:
--
Assignee: Prince Mahajan (was: David Jacot)
> Committed offsets could be deleted dur
ijuma merged pull request #11739:
URL: https://github.com/apache/kafka/pull/11739
--
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...
[
https://issues.apache.org/jira/browse/KAFKA-13649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-13649:
Assignee: Jason Gustafson
> StandardAuthorizer should not finish loading until it reads u
[
https://issues.apache.org/jira/browse/KAFKA-13649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13649:
-
Description: StandardAuthorizer should not finish loading until it reads up
to the high water ma
[
https://issues.apache.org/jira/browse/KAFKA-13649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-13649:
Assignee: Jose Armando Garcia Sancio (was: Jason Gustafson)
> StandardAuthorizer should
Colin McCabe created KAFKA-13657:
Summary: StandardAuthorizer should implement the early start
listener logic described in KIP-801
Key: KAFKA-13657
URL: https://issues.apache.org/jira/browse/KAFKA-13657
hachikuji commented on a change in pull request #11737:
URL: https://github.com/apache/kafka/pull/11737#discussion_r801974824
##
File path: docs/upgrade.html
##
@@ -19,56 +19,6 @@
hachikuji merged pull request #11737:
URL: https://github.com/apache/kafka/pull/11737
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13400.
-
Resolution: Not A Bug
Based on the information provided, the conclusion seems to be that
ijuma merged pull request #11741:
URL: https://github.com/apache/kafka/pull/11741
--
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...
hachikuji commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802060134
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache S
hachikuji commented on a change in pull request #11677:
URL: https://github.com/apache/kafka/pull/11677#discussion_r802068290
##
File path: metadata/src/main/resources/common/metadata/FeatureLevelRecord.json
##
@@ -22,9 +22,7 @@
"fields": [
{ "name": "Name", "type": "st
cmccabe commented on pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#issuecomment-1033076185
Failed tests were:
```
ConnectionQuotasTest#testNonDefaultConnectionCountLimitAndRateLimit
DynamicBrokerReconfigurationTest#testThreadPoolResize
```
These tests ar
[
https://issues.apache.org/jira/browse/KAFKA-13558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-13558:
--
Description:
{{NioEchoServer}} does not close the selectors that it opens. The result of
this can be
[
https://issues.apache.org/jira/browse/KAFKA-13655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mario Mastrodicasa updated KAFKA-13655:
---
Description:
Dear administrator,
I want to add references to a new .NET Kafka Clien
guozhangwang commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1033152747
> @RivenSun2 , I checked the build results after your rebase, there's a test
ConsumerBounceTest.testClose that failed twice with NPE. That looks suspicious
and didn't fail
hachikuji commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802061270
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apac
guozhangwang commented on a change in pull request #11738:
URL: https://github.com/apache/kafka/pull/11738#discussion_r802144978
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apac
ijuma closed pull request #10415:
URL: https://github.com/apache/kafka/pull/10415
--
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...
hachikuji commented on a change in pull request #11667:
URL: https://github.com/apache/kafka/pull/11667#discussion_r802153736
##
File path:
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala
##
@@ -34,18 +36,25 @@ import scala.jdk.CollectionConverters._
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802160529
##
File path:
metadata/src/main/java/org/apache/kafka/controller/AclControlManager.java
##
@@ -0,0 +1,232 @@
+/*
+ * Licensed to the Apache Software Foun
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802160529
##
File path:
metadata/src/main/java/org/apache/kafka/controller/AclControlManager.java
##
@@ -0,0 +1,232 @@
+/*
+ * Licensed to the Apache Software Foun
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802162821
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/ClusterMetadataAuthorizer.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apa
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802164182
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802164975
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802165236
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802165841
##
File path:
metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache
hachikuji commented on a change in pull request #11616:
URL: https://github.com/apache/kafka/pull/11616#discussion_r801172935
##
File path: config/producer.properties
##
@@ -23,7 +23,7 @@ bootstrap.servers=localhost:9092
# specify the compression codec for all data generated:
hachikuji commented on a change in pull request #11655:
URL: https://github.com/apache/kafka/pull/11655#discussion_r802172051
##
File path:
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala
##
@@ -37,7 +38,8 @@ class CreateTopicsRequestWithPolicyTes
cmccabe commented on a change in pull request #11649:
URL: https://github.com/apache/kafka/pull/11649#discussion_r802177256
##
File path:
metadata/src/main/java/org/apache/kafka/controller/AclControlManager.java
##
@@ -0,0 +1,232 @@
+/*
+ * Licensed to the Apache Software Foun
tusharg1993 commented on a change in pull request #11204:
URL: https://github.com/apache/kafka/pull/11204#discussion_r802200036
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClientResponseWithFinalize.java
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Softw
RivenSun2 commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1033258042
@guozhangwang @showuon
In fact, I ran ConsumerBounceTest.testClose() several times locally
yesterday, and the testCase can all pass. I guess the jenkins environment is
u
RivenSun2 edited a comment on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1033258042
@guozhangwang @showuon
In fact, I ran ConsumerBounceTest.testClose() several times locally
yesterday, and the testCase can all pass. I guess the jenkins environmen
Shivakumar created KAFKA-13658:
--
Summary: Upgrade vulnerable dependencies jan 2022
Key: KAFKA-13658
URL: https://issues.apache.org/jira/browse/KAFKA-13658
Project: Kafka
Issue Type: Bug
Affe
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shivakumar updated KAFKA-13658:
---
Description:
|Packages|Package Version|CVSS|Fix Status|
|com.fasterxml.jackson.core_jackson-databind
RivenSun2 commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1033364540
`DynamicBrokerReconfigurationTest.testThreadPoolResize()` and
`RebalanceSourceConnectorsIntegrationTest.testRemovingWorker()`
The failed testCases are not related to this
prince-mahajan opened a new pull request #11742:
URL: https://github.com/apache/kafka/pull/11742
Fix for bug where group coordinator can garbage collect offsets for groups
that are in flux: https://issues.apache.org/jira/browse/KAFKA-13636)
Tested: Added a test; ensured that it fails
dengziming commented on a change in pull request #11655:
URL: https://github.com/apache/kafka/pull/11655#discussion_r802289648
##
File path:
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala
##
@@ -55,11 +63,9 @@ class CreateTopicsRequestWithPolicyT
guozhangwang commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1033414741
Yeah I think I agree with you now, the failed cases for 2.12 is
`connect.integration` and for 2.13 is `DynamicBrokerReconfiguration` which is
known to be a bit flaky.
--
guozhangwang merged pull request #11340:
URL: https://github.com/apache/kafka/pull/11340
--
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
guozhangwang commented on pull request #11340:
URL: https://github.com/apache/kafka/pull/11340#issuecomment-1033416495
Merged to trunk, thanks @RivenSun2 !
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-13310:
-
Assignee: RivenSun
> KafkaConsumer cannot jump out of the poll method, and the consumer
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13310:
--
Labels: new-rebalance-should-fix (was: )
> KafkaConsumer cannot jump out of the poll method,
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13310.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> KafkaConsumer cannot jump out of the poll me
69 matches
Mail list logo
