[
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
[
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 reassigned KAFKA-13310:
-
Assignee: RivenSun
> KafkaConsumer cannot jump out of the poll method, and the consumer
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
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-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.
--
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
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
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
[
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
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
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
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
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
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
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
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:
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
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_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_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_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_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
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._
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...
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
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 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
[
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
[
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
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
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
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
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...
[
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
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
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 @@
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
[
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
[
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
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-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
[
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-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
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
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
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
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
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
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
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
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
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
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.
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:
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.
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-
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
--
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
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 #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 `
[
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
>
[
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
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
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
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
[
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
>
69 matches
Mail list logo
