Owen-CH-Leung commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1548103258
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +420,15 @@ private String[] addBootstrapServer(String... args) {
gharris1727 commented on PR #15639:
URL: https://github.com/apache/kafka/pull/15639#issuecomment-2032352619
Hi @chia7712 This [test is disabled in
chia7712 commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1548067397
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +420,15 @@ private String[] addBootstrapServer(String... args) {
return
[
https://issues.apache.org/jira/browse/KAFKA-16418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16418:
---
Summary: Review/split long-running admin client integration tests (was:
Split long-running
Owen-CH-Leung commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1548061572
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +420,15 @@ private String[] addBootstrapServer(String... args) {
chia7712 commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1547986293
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +420,15 @@ private String[] addBootstrapServer(String... args) {
return
[
https://issues.apache.org/jira/browse/KAFKA-16297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-16297:
Fix Version/s: 3.8.0
> Race condition while promoting future replica can lead to partition
>
[
https://issues.apache.org/jira/browse/KAFKA-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-16234:
Fix Version/s: 3.8.0
> Log directory failure re-creates partitions in another logdir
[
https://issues.apache.org/jira/browse/KAFKA-16082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-16082:
Fix Version/s: 3.8.0
> Broker recreates reassigned partition after logdir failure
>
lianetm commented on PR #15585:
URL: https://github.com/apache/kafka/pull/15585#issuecomment-2032154288
Hey @Phuc-Hong-Tran , any update on this one? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
funky-eyes commented on PR #15034:
URL: https://github.com/apache/kafka/pull/15034#issuecomment-2032110132
> @funky-eyes let me know if you got a chance to review my comment
Hello, thank you for your reminder. I submitted this PR to make the
functions of recordheader and list
chia7712 commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1547934887
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +447,15 @@ private String[] addBootstrapServer(String... args) {
return
mjsax commented on PR #15189:
URL: https://github.com/apache/kafka/pull/15189#issuecomment-2032098989
Just merged https://github.com/apache/kafka/pull/15510 -- can we move
forward with this PR (maybe by rebasing it to see if any tests break?)?
--
This is an automated message from the
mjsax commented on PR #15510:
URL: https://github.com/apache/kafka/pull/15510#issuecomment-2032092184
Thanks for the fix @VictorvandenHoven! Merged to `trunk`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
mjsax merged PR #15510:
URL: https://github.com/apache/kafka/pull/15510
--
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:
mjsax commented on code in PR #15619:
URL: https://github.com/apache/kafka/pull/15619#discussion_r1543277915
##
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java:
##
@@ -596,7 +597,9 @@ public synchronized StreamsBuilder
addGlobalStore(final StoreBuilder s
[
https://issues.apache.org/jira/browse/KAFKA-16458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16458:
Labels: needs-kip (was: )
> Add contains method in KeyValue store interface
>
Ayoub Omari created KAFKA-16458:
---
Summary: Add contains method in KeyValue store interface
Key: KAFKA-16458
URL: https://issues.apache.org/jira/browse/KAFKA-16458
Project: Kafka
Issue Type:
Owen-CH-Leung commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1547789497
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +447,15 @@ private String[] addBootstrapServer(String... args) {
Joker-5 commented on code in PR #15642:
URL: https://github.com/apache/kafka/pull/15642#discussion_r1547632847
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -343,7 +346,7 @@ public void
Joker-5 commented on code in PR #15642:
URL: https://github.com/apache/kafka/pull/15642#discussion_r1547690392
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -69,6 +69,9 @@ public static void setup() {
Joker-5 commented on code in PR #15642:
URL: https://github.com/apache/kafka/pull/15642#discussion_r1547690392
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -69,6 +69,9 @@ public static void setup() {
rykovsi opened a new pull request, #15646:
URL: https://github.com/apache/kafka/pull/15646
[KAFKA-16457](https://issues.apache.org/jira/browse/KAFKA-16457)
Useless import class in SslConfigs.java
import org.apache.kafka.common.config.ConfigDef.Type;
...
Svyatoslav created KAFKA-16457:
--
Summary: Useless import class
Key: KAFKA-16457
URL: https://issues.apache.org/jira/browse/KAFKA-16457
Project: Kafka
Issue Type: Task
Components:
[
https://issues.apache.org/jira/browse/KAFKA-16457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Svyatoslav updated KAFKA-16457:
---
Description:
Useless import class in SslConfigs.java
{code:java}
import
Joker-5 commented on code in PR #15642:
URL: https://github.com/apache/kafka/pull/15642#discussion_r1547632847
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -343,7 +346,7 @@ public void
Joker-5 commented on code in PR #15642:
URL: https://github.com/apache/kafka/pull/15642#discussion_r1547609546
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -331,7 +334,7 @@ public void
nizhikov commented on PR #15645:
URL: https://github.com/apache/kafka/pull/15645#issuecomment-2031645630
Hello @chia7712 This is first PR that moves parts of ConfigCommand to java.
It contains rewritten `ConfigCommandIntegrationTest`.
Please, take a look.
--
This is an automated
nizhikov opened a new pull request, #15645:
URL: https://github.com/apache/kafka/pull/15645
This is first part of #15417 refactoring.
PR intention - split big PR in parts to simplify review.
PR contains `ConfigCommandIntegrationTest` rewritten in java
### Committer Checklist
[
https://issues.apache.org/jira/browse/KAFKA-16148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16148.
-
Fix Version/s: 3.8.0
Resolution: Fixed
> Implement GroupMetadataManager#onUnloaded
>
dajac merged PR #15446:
URL: https://github.com/apache/kafka/pull/15446
--
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:
vamossagar12 commented on PR #15034:
URL: https://github.com/apache/kafka/pull/15034#issuecomment-2031571928
@funky-eyes let me know if you got a chance to review my comment
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vamossagar12 commented on PR #15556:
URL: https://github.com/apache/kafka/pull/15556#issuecomment-2031549949
@johnnychhsu ,for completeness sake, the issue with private constructor
related noise in the logs is being fixed in this PR:
https://github.com/apache/kafka/pull/15642
--
This is
vamossagar12 commented on code in PR #15642:
URL: https://github.com/apache/kafka/pull/15642#discussion_r1547506743
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -343,7 +346,7 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-16456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833062#comment-17833062
]
Chia-Ping Tsai commented on KAFKA-16456:
the debug message "Received {} response from node {}
Prashant-Jagtap opened a new pull request, #15644:
URL: https://github.com/apache/kafka/pull/15644
We would like to add support for s390x to existing CI. Adding s390x build
stage which uses Jdk21 and Scala 2.13.
Verified the build and tests locally.
### Committer Checklist
Rajan Choudhary created KAFKA-16456:
---
Summary: Can't stop kafka debug logs
Key: KAFKA-16456
URL: https://issues.apache.org/jira/browse/KAFKA-16456
Project: Kafka
Issue Type: Bug
appchemist opened a new pull request, #15643:
URL: https://github.com/apache/kafka/pull/15643
fix typo
amd -> and
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
Owen-CH-Leung commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1547302390
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +447,15 @@ private String[] addBootstrapServer(String... args) {
Owen-CH-Leung commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1547303323
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -94,15 +101,47 @@ private void setUp() {
}
}
+private void
Owen-CH-Leung commented on code in PR #15489:
URL: https://github.com/apache/kafka/pull/15489#discussion_r1547302390
##
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java:
##
@@ -391,4 +447,15 @@ private String[] addBootstrapServer(String... args) {
chia7712 commented on PR #15639:
URL: https://github.com/apache/kafka/pull/15639#issuecomment-2031262693
@gharris1727 just curious. How do you notice that incorrect changes? Are
there failed tests related to #15597?
--
This is an automated message from the Apache Git Service.
To respond
Joker-5 opened a new pull request, #15642:
URL: https://github.com/apache/kafka/pull/15642
Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin
scanning errors
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [
showuon merged PR #15610:
URL: https://github.com/apache/kafka/pull/15610
--
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:
showuon commented on PR #15610:
URL: https://github.com/apache/kafka/pull/15610#issuecomment-2031206526
Failed tests are unrelated.
--
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
101 - 145 of 145 matches
Mail list logo