MAHDI JAFARPUR created KAFKA-16590:
--
Summary: Current offset is higher than last offset
Key: KAFKA-16590
URL: https://issues.apache.org/jira/browse/KAFKA-16590
Project: Kafka
Issue Type: Bug
frankvicky opened a new pull request, #15760:
URL: https://github.com/apache/kafka/pull/15760
# MINOR: Fixed incorrect references for
SASL_OAUTHBEARER_SCOPE_CLAIM_NAME_DEFAULT and
SASL_OAUTHBEARER_SUB_CLAIM_NAME_DEFAULT
Change from:
```java
public static final String SASL_OAUTH
frankvicky commented on PR #15760:
URL: https://github.com/apache/kafka/pull/15760#issuecomment-2067594880
@chia7712 Hello, could you please assist me with reviewing this pull request
?
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
chia7712 commented on code in PR #15656:
URL: https://github.com/apache/kafka/pull/15656#discussion_r1573199471
##
server/src/main/java/org/apache/kafka/server/config/KafkaSecurityConfigs.java:
##
@@ -0,0 +1,239 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
chia7712 commented on PR #15760:
URL: https://github.com/apache/kafka/pull/15760#issuecomment-2067595468
@frankvicky thanks for this quick fix. I will check it later
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
soarez commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1573203822
##
core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala:
##
@@ -950,16 +980,47 @@ class ZkMigrationIntegrationTest {
dataOpt.map(ProducerIdBloc
brandboat opened a new pull request, #15761:
URL: https://github.com/apache/kafka/pull/15761
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upg
[
https://issues.apache.org/jira/browse/KAFKA-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839225#comment-17839225
]
Walter Hernandez edited comment on KAFKA-16567 at 4/20/24 11:30 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839225#comment-17839225
]
Walter Hernandez commented on KAFKA-16567:
--
I noticed that KIP-869 not only int
chia7712 merged PR #15757:
URL: https://github.com/apache/kafka/pull/15757
--
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...@kafka.apache
Chia-Ping Tsai created KAFKA-16591:
--
Summary: RaftClusterInvocationContext ought to clear the admin
queue when stopping
Key: KAFKA-16591
URL: https://issues.apache.org/jira/browse/KAFKA-16591
Project
Sagar Rao created KAFKA-16592:
-
Summary: ConfigKey constructor update can break clients using it
Key: KAFKA-16592
URL: https://issues.apache.org/jira/browse/KAFKA-16592
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-16591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839230#comment-17839230
]
TengYao Chi commented on KAFKA-16591:
-
I am able to handle this issue. :)
> RaftClu
chia7712 merged PR #15719:
URL: https://github.com/apache/kafka/pull/15719
--
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...@kafka.apache
[
https://issues.apache.org/jira/browse/KAFKA-16552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16552.
Fix Version/s: 3.8.0
Resolution: Fixed
> Create an internal config to control Initi
chia7712 commented on code in PR #15616:
URL: https://github.com/apache/kafka/pull/15616#discussion_r1573271296
##
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala:
##
@@ -116,6 +118,57 @@ class AlterReplicaLogDirsRequestTest extends
BaseRequestTest {
[
https://issues.apache.org/jira/browse/KAFKA-16591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16591:
--
Assignee: TengYao Chi
> RaftClusterInvocationContext ought to clear the admin queue w
Chia-Ping Tsai created KAFKA-16593:
--
Summary: Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions
Key: KAFKA-16593
URL: https://issues.apache.org/jira/browse/KAFKA-16593
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839240#comment-17839240
]
Sal Sorrentino commented on KAFKA-16514:
I spent a little time looking at the co
[
https://issues.apache.org/jira/browse/KAFKA-16514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839240#comment-17839240
]
Sal Sorrentino edited comment on KAFKA-16514 at 4/20/24 1:32 PM:
-
frankvicky opened a new pull request, #15763:
URL: https://github.com/apache/kafka/pull/15763
[KAFKA-16591](https://issues.apache.org/jira/browse/KAFKA-16591)
After closing all admins, we should also clear the queue of admins.
--
This is an automated message from the Apache Git
frankvicky commented on PR #15762:
URL: https://github.com/apache/kafka/pull/15762#issuecomment-2067692915
@chia7712 Could you please assist me with reviewing this pull request ? 😃
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
frankvicky commented on PR #15763:
URL: https://github.com/apache/kafka/pull/15763#issuecomment-2067693222
@chia7712 Could you please assist me with reviewing this pull request ? 😄
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
brandboat commented on code in PR #15758:
URL: https://github.com/apache/kafka/pull/15758#discussion_r1573311578
##
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java:
##
@@ -61,7 +61,7 @@ public void testParseAndValidateAddressesWithReverseLookup() {
a
brandboat commented on code in PR #15758:
URL: https://github.com/apache/kafka/pull/15758#discussion_r1573311578
##
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java:
##
@@ -61,7 +61,7 @@ public void testParseAndValidateAddressesWithReverseLookup() {
a
brandboat commented on code in PR #15758:
URL: https://github.com/apache/kafka/pull/15758#discussion_r1573311578
##
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java:
##
@@ -61,7 +61,7 @@ public void testParseAndValidateAddressesWithReverseLookup() {
a
[
https://issues.apache.org/jira/browse/KAFKA-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ayoub Omari reassigned KAFKA-16573:
---
Assignee: Ayoub Omari
> Streams does not specify where a Serde is needed
>
[
https://issues.apache.org/jira/browse/KAFKA-16573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839274#comment-17839274
]
Ayoub Omari commented on KAFKA-16573:
-
Thanks [~mjsax], I am going to work on it in
chia7712 merged PR #15760:
URL: https://github.com/apache/kafka/pull/15760
--
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...@kafka.apache
chia7712 commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573445048
##
clients/src/main/java/org/apache/kafka/common/network/Selector.java:
##
@@ -1281,14 +1281,14 @@ private Meter createMeter(Metrics metrics, String
groupName, Map m
chia7712 merged PR #15763:
URL: https://github.com/apache/kafka/pull/15763
--
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...@kafka.apache
[
https://issues.apache.org/jira/browse/KAFKA-16591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16591.
Fix Version/s: 3.8.0
Resolution: Fixed
> RaftClusterInvocationContext ought to clea
chia7712 commented on code in PR #15762:
URL: https://github.com/apache/kafka/pull/15762#discussion_r1573448544
##
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java:
##
@@ -1256,6 +1256,15 @@ public static class ConfigKey {
public final boolean interna
lbradstreet opened a new pull request, #15764:
URL: https://github.com/apache/kafka/pull/15764
Minor javadoc argument rename to match the actual argument name in the
method.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
emitskevich-blp commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573454740
##
clients/src/main/java/org/apache/kafka/common/network/Selector.java:
##
@@ -1281,14 +1281,14 @@ private Meter createMeter(Metrics metrics, String
groupName,
chia7712 commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1573452044
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -139,28 +159,46 @@ public Map nameTags() {
return tags;
}
-public ClusterConfig copyOf()
emitskevich-blp commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573458599
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1012,6 +1013,28 @@ public void testChannelCloseWhileProcessingReceives()
thr
emitskevich-blp commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573458599
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1012,6 +1013,28 @@ public void testChannelCloseWhileProcessingReceives()
thr
emitskevich-blp commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573458599
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1012,6 +1013,28 @@ public void testChannelCloseWhileProcessingReceives()
thr
chia7712 commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573465553
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1012,6 +1013,28 @@ public void testChannelCloseWhileProcessingReceives()
throws Exc
chia7712 commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573465932
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1012,6 +1013,28 @@ public void testChannelCloseWhileProcessingReceives()
throws Exc
emitskevich-blp commented on code in PR #15722:
URL: https://github.com/apache/kafka/pull/15722#discussion_r1573473787
##
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java:
##
@@ -1012,6 +1013,28 @@ public void testChannelCloseWhileProcessingReceives()
thr
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1573570386
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -139,28 +159,46 @@ public Map nameTags() {
return tags;
}
-public ClusterConfig copyOf(
appchemist commented on PR #15647:
URL: https://github.com/apache/kafka/pull/15647#issuecomment-2067889913
@kirktrue, PTAL, thanks in advance.
--
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
appchemist closed pull request #14765: MINOR: clear inFlightCorrelationId when
ConnectionState is changed to READY
URL: https://github.com/apache/kafka/pull/14765
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/KAFKA-16549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839313#comment-17839313
]
charliecheng commented on KAFKA-16549:
--
I would like to work on this.
> suppress t
[
https://issues.apache.org/jira/browse/KAFKA-16549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16549:
--
Assignee: charliecheng (was: Chia-Ping Tsai)
> suppress the warnings from RemoteLogM
[
https://issues.apache.org/jira/browse/KAFKA-16593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839316#comment-17839316
]
TengYao Chi commented on KAFKA-16593:
-
I am able to handle this.
> Rewrite DeleteCo
[
https://issues.apache.org/jira/browse/KAFKA-16593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16593:
--
Assignee: TengYao Chi
> Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions
>
FrankYang0529 commented on code in PR #15679:
URL: https://github.com/apache/kafka/pull/15679#discussion_r1573623165
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java:
##
@@ -16,7 +16,15 @@
*/
package org.apache
[
https://issues.apache.org/jira/browse/KAFKA-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839323#comment-17839323
]
Ming-Yen Chung commented on KAFKA-16547:
Hi [~chia7712],Â
I would like to do it
[
https://issues.apache.org/jira/browse/KAFKA-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-16547:
-
Assignee: Ming-Yen Chung (was: Yu-Lin Chen)
> add test for DescribeConfigsOptions#includeDocum
m1a2st commented on PR #15765:
URL: https://github.com/apache/kafka/pull/15765#issuecomment-2067922075
@chia7712
--
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 unsubsc
chia7712 commented on code in PR #15765:
URL: https://github.com/apache/kafka/pull/15765#discussion_r1573633727
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -463,7 +464,9 @@ private Optional
lookupTimestamp(RemoteLogSegmen
RecordBatch bat
frankvicky opened a new pull request, #15766:
URL: https://github.com/apache/kafka/pull/15766
Rewrite DeleteConsumerGroupsTest by ClusterTestExtensions.
--
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
brandboat commented on code in PR #15761:
URL: https://github.com/apache/kafka/pull/15761#discussion_r1573635829
##
core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala:
##
@@ -17,48 +17,78 @@
package kafka.server
-import kafka.test.{ClusterConfig, ClusterInst
56 matches
Mail list logo
