jolshan commented on code in PR #14607:
URL: https://github.com/apache/kafka/pull/14607#discussion_r1560454922
##
storage/src/main/java/org/apache/kafka/storage/internals/checkpoint/PartitionMetadataFile.java:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836006#comment-17836006
]
Shikhar commented on KAFKA-10788:
-
Hi [~sagarrao]
Is this issue resolved? If not, can I work on this
HiroArai created KAFKA-16510:
Summary: java.lang.OutOfMemoryError in kafka-metadata-quorum.sh
Key: KAFKA-16510
URL: https://issues.apache.org/jira/browse/KAFKA-16510
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-16006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835989#comment-17835989
]
HiroArai commented on KAFKA-16006:
--
mee too I saw same error in the test.
> mTLS authentication works
github-actions[bot] commented on PR #15115:
URL: https://github.com/apache/kafka/pull/15115#issuecomment-2048870549
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
KevinZTW commented on code in PR #15676:
URL: https://github.com/apache/kafka/pull/15676#discussion_r1560373161
##
core/src/test/scala/integration/kafka/coordinator/transaction/ProducerIdsIntegrationTest.scala:
##
@@ -19,32 +19,31 @@ package kafka.coordinator.transaction
[
https://issues.apache.org/jira/browse/KAFKA-16507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16507:
--
Component/s: clients
> Add raw record into RecordDeserialisationException
>
[
https://issues.apache.org/jira/browse/KAFKA-16507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16507:
-
Assignee: Fred Rouleau
> Add raw record into RecordDeserialisationException
>
kirktrue commented on code in PR #15691:
URL: https://github.com/apache/kafka/pull/15691#discussion_r1560342179
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java:
##
@@ -326,7 +327,17 @@ ConsumerRecord parseRecord(Deserializers
dongnuo123 commented on code in PR #15662:
URL: https://github.com/apache/kafka/pull/15662#discussion_r1560320708
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -180,12 +192,19 @@ public static class DeadlineAndEpoch {
dongnuo123 commented on code in PR #15662:
URL: https://github.com/apache/kafka/pull/15662#discussion_r1560320708
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -180,12 +192,19 @@ public static class DeadlineAndEpoch {
dongnuo123 commented on code in PR #15662:
URL: https://github.com/apache/kafka/pull/15662#discussion_r1560315985
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -761,6 +776,58 @@ public ClassicGroup classicGroup(
mumrah commented on code in PR #15695:
URL: https://github.com/apache/kafka/pull/15695#discussion_r1560175751
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -657,15 +657,19 @@ class KafkaServer(
}
private def createCurrentControllerIdMetric(): Unit = {
-
cmccabe commented on code in PR #15695:
URL: https://github.com/apache/kafka/pull/15695#discussion_r1560167894
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -657,15 +657,19 @@ class KafkaServer(
}
private def createCurrentControllerIdMetric(): Unit = {
-
cmccabe commented on code in PR #15695:
URL: https://github.com/apache/kafka/pull/15695#discussion_r1560168052
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -657,15 +657,19 @@ class KafkaServer(
}
private def createCurrentControllerIdMetric(): Unit = {
-
mumrah commented on code in PR #15695:
URL: https://github.com/apache/kafka/pull/15695#discussion_r1560161829
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -657,15 +657,19 @@ class KafkaServer(
}
private def createCurrentControllerIdMetric(): Unit = {
-
infantlikesprogramming opened a new pull request, #15696:
URL: https://github.com/apache/kafka/pull/15696
*When creating a topic in KRaft cluster, a config value returned by
createTopics() is different than what you get from describeConfigs().*
*My guess from reading the code is
soarez commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1560139446
##
core/src/main/java/kafka/server/TierStateMachine.java:
##
@@ -40,7 +92,72 @@ public interface TierStateMachine {
*/
PartitionFetchState
[
https://issues.apache.org/jira/browse/KAFKA-16509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-16509:
Assignee: Colin McCabe
> CurrentControllerId metric is unreliable in ZK mode
>
cmccabe opened a new pull request, #15695:
URL: https://github.com/apache/kafka/pull/15695
The CurrentControllerId metric added by KIP-1001 is unreliable in ZK mode.
Sometimes when there is no active ZK-based controller, it still shows the
previous controller ID. Instead, it should show -1
Colin McCabe created KAFKA-16509:
Summary: CurrentControllerId metric is unreliable in ZK mode
Key: KAFKA-16509
URL: https://issues.apache.org/jira/browse/KAFKA-16509
Project: Kafka
Issue
kirktrue commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1559907295
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -157,8 +157,10 @@ public class AsyncKafkaConsumerTest {
[
https://issues.apache.org/jira/browse/KAFKA-16466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835846#comment-17835846
]
Ilya Zakharov commented on KAFKA-16466:
---
[~chiacyu] Hello! Сan you tell me if you're working on
dajac merged PR #15411:
URL: https://github.com/apache/kafka/pull/15411
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16294.
-
Fix Version/s: 3.8.0
Resolution: Fixed
> Add group protocol migration enabling config
>
kirktrue commented on PR #15408:
URL: https://github.com/apache/kafka/pull/15408#issuecomment-2048153273
@lucasbru—sorry that I've forgotten, but why don't we want to merge this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
kirktrue commented on PR #15688:
URL: https://github.com/apache/kafka/pull/15688#issuecomment-2048148062
@philipnee—sorry I'm late to the party, but why do we submit the event to
the queue when the timeout is 0?
--
This is an automated message from the Apache Git Service.
To respond to
mimaison commented on PR #15516:
URL: https://github.com/apache/kafka/pull/15516#issuecomment-2048128916
@divijvaidya It seems you've done a bit of work around compression in the
past. Can you take a look? Thanks
--
This is an automated message from the Apache Git Service.
To respond to
mimaison commented on PR #10826:
URL: https://github.com/apache/kafka/pull/10826#issuecomment-2048127235
I opened https://github.com/apache/kafka/pull/15516 to implement this KIP.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lucasbru commented on code in PR #15661:
URL: https://github.com/apache/kafka/pull/15661#discussion_r1559790393
##
tests/kafkatest/services/verifiable_consumer.py:
##
@@ -135,6 +135,28 @@ def last_commit(self, tp):
else:
return None
+# This needs to be
lucasbru merged PR #15661:
URL: https://github.com/apache/kafka/pull/15661
--
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:
chia7712 commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559774590
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java:
##
@@ -16,14 +16,132 @@
*/
package
izmal commented on PR #10277:
URL: https://github.com/apache/kafka/pull/10277#issuecomment-2047967071
I my case reason for replication cycle was:
`replication.policy.separator = -`
With another separator works without cycle (e.g '_'). :-)
--
This is an automated message from the
lucasbru commented on PR #15693:
URL: https://github.com/apache/kafka/pull/15693#issuecomment-2047947707
@lianetm You have reviewed those changes already as part of
https://github.com/apache/kafka/pull/15613 .
--
This is an automated message from the Apache Git Service.
To respond to the
OmniaGM commented on PR #15684:
URL: https://github.com/apache/kafka/pull/15684#issuecomment-2047947749
ugh my local environment keep the wrong caches because I keep jump between
branches
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
lucasbru commented on PR #15613:
URL: https://github.com/apache/kafka/pull/15613#issuecomment-2047945261
Hey @lianetm. I split the PR into two, the changes for the legacy consumer
go into https://github.com/apache/kafka/pull/15693.
--
This is an automated message from the Apache Git
lucasbru opened a new pull request, #15693:
URL: https://github.com/apache/kafka/pull/15693
The javadoc for `KafkaConsumer.commitSync` says:
> Note that asynchronous offset commits sent previously with the
{https://github.com/link #commitAsync(OffsetCommitCallback)}
> (or similar)
chia7712 commented on PR #15684:
URL: https://github.com/apache/kafka/pull/15684#issuecomment-2047933442
@OmniaGM it seems there are build error. could you fix them?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
OmniaGM commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559709137
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
OmniaGM commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559706475
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
chia7712 commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559703336
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import
Matthias J. Sax created KAFKA-16508:
---
Summary: Infinte loop if output topic does not exisit
Key: KAFKA-16508
URL: https://issues.apache.org/jira/browse/KAFKA-16508
Project: Kafka
Issue
OmniaGM commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559689777
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
OmniaGM commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559689777
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
OmniaGM commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559689777
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
fred-ro opened a new pull request, #15691:
URL: https://github.com/apache/kafka/pull/15691
Add raw ConsumerRecord data to RecordDeserialisationException to make DLQ
implementation easier
*Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or
[
https://issues.apache.org/jira/browse/KAFKA-16507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred Rouleau updated KAFKA-16507:
-
Labels: kip (was: )
> Add raw record into RecordDeserialisationException
>
Fred Rouleau created KAFKA-16507:
Summary: Add raw record into RecordDeserialisationException
Key: KAFKA-16507
URL: https://issues.apache.org/jira/browse/KAFKA-16507
Project: Kafka
Issue
OmniaGM commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559674776
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
[
https://issues.apache.org/jira/browse/KAFKA-16505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16505:
Component/s: streams
> KIP-1034: Dead letter queue in Kafka Streams
>
[
https://issues.apache.org/jira/browse/KAFKA-16505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16505:
Labels: KIP (was: )
> KIP-1034: Dead letter queue in Kafka Streams
>
philipnee commented on code in PR #15661:
URL: https://github.com/apache/kafka/pull/15661#discussion_r1559662337
##
tests/kafkatest/services/verifiable_consumer.py:
##
@@ -135,6 +135,28 @@ def last_commit(self, tp):
else:
return None
+# This needs to be
[
https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-15309:
Assignee: Alieh Saeedi
> Add custom error handler to Producer
>
chia7712 commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559616179
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import
mimaison commented on code in PR #15558:
URL: https://github.com/apache/kafka/pull/15558#discussion_r1559584216
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java:
##
@@ -320,4 +323,21 @@ static void createCompactedTopic(String topicName, short
[
https://issues.apache.org/jira/browse/KAFKA-16502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16502:
Component/s: streams
unit tests
> Fix flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-16502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16502:
Labels: flaky-test (was: )
> Fix flaky
>
dajac commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559600382
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
[
https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835763#comment-17835763
]
Kiriakos Marantidis commented on KAFKA-16336:
-
Hi [~mjsax] , I would like to work on this
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16506:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> add the scala version of tool-related
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835754#comment-17835754
]
Chia-Ping Tsai commented on KAFKA-16506:
[~yangpoan]thanks for taking over this jira. please
chia7712 commented on code in PR #15670:
URL: https://github.com/apache/kafka/pull/15670#discussion_r1559526460
##
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManagerConfig.java:
##
@@ -17,13 +17,12 @@
package
OmniaGM commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559529499
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import org.apache.kafka.common.record.CompressionType;
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835749#comment-17835749
]
PoAn Yang commented on KAFKA-16506:
---
Hi [~chia7712], I'm interested in this. May I assign to myself?
chia7712 merged PR #15656:
URL: https://github.com/apache/kafka/pull/15656
--
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:
lucasbru commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1559430603
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java:
##
@@ -229,7 +229,11 @@ private GroupRebalanceConfig
chia7712 commented on PR #15678:
URL: https://github.com/apache/kafka/pull/15678#issuecomment-2047578617
> If the condition doesn't meet within the maxWaitMs, the waitForCondition
would throw the assertion failure. Do we need another timeout to handle that?
My origin thought was to
vamossagar12 commented on PR #13801:
URL: https://github.com/apache/kafka/pull/13801#issuecomment-2047548232
Chris, I started changing the tests in alignment with the comments (i.e
using AtomicBoolean, AtomicReference and removing try-catch block). I noticed
an interesting issue with
Chia-Ping Tsai created KAFKA-16506:
--
Summary: add the scala version of tool-related class back to core
module to follow KIP-906
Key: KAFKA-16506
URL: https://issues.apache.org/jira/browse/KAFKA-16506
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16506:
--
Assignee: Chia-Ping Tsai
> add the scala version of tool-related class back to core
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-16506:
---
Summary: add the scala version of tool-related classes back to core module
to follow
[
https://issues.apache.org/jira/browse/KAFKA-14517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phuc Hong Tran reassigned KAFKA-14517:
--
Assignee: Phuc Hong Tran (was: Jimmy Wang)
> Implement regex subscriptions
>
chia7712 commented on code in PR #15684:
URL: https://github.com/apache/kafka/pull/15684#discussion_r1559398541
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java:
##
@@ -20,16 +20,51 @@
import
chia7712 commented on code in PR #15676:
URL: https://github.com/apache/kafka/pull/15676#discussion_r1559385018
##
core/src/test/scala/integration/kafka/coordinator/transaction/ProducerIdsIntegrationTest.scala:
##
@@ -19,32 +19,31 @@ package kafka.coordinator.transaction
nizhikov commented on PR #15645:
URL: https://github.com/apache/kafka/pull/15645#issuecomment-2047311878
> I mean we can add more tests for zk and kraft in this PR, and it would be
nice to use new test infra (ClusterTestExtensions) to rewrite it. WDYT?
Agree. I will try to extend
[
https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-15309:
Assignee: (was: Alieh Saeedi)
> Add custom error handler to Producer
>
showuon commented on PR #15136:
URL: https://github.com/apache/kafka/pull/15136#issuecomment-2047306952
Will check it again within this week. 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 above to go
chia7712 commented on PR #15645:
URL: https://github.com/apache/kafka/pull/15645#issuecomment-2047302613
> I thought we want to move all code related to the ConfigCommand to java
and remove it when ZK support will be dropped.
Personally, rewriting a class which will get removed
[
https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi reassigned KAFKA-15309:
Assignee: Alieh Saeedi
> Add custom error handler to Producer
>
[
https://issues.apache.org/jira/browse/KAFKA-15568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-15568.
Resolution: Duplicate
duplicate to KAFKA-16181
> Use incrementalAlterConfigs to update
vamossagar12 commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1559256180
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java:
##
@@ -533,6 +537,45 @@ public void
vamossagar12 commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1559253060
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java:
##
@@ -533,6 +536,47 @@ public void
chiacyu commented on PR #15678:
URL: https://github.com/apache/kafka/pull/15678#issuecomment-2047169130
If the condition doesn't meet within the maxWaitMs, the waitForCondition
would throw the assertion failure. Do we need another timeout to handle that?
--
This is an automated message
showuon commented on PR #15522:
URL: https://github.com/apache/kafka/pull/15522#issuecomment-2047096126
@soarez , oops, there's conflict due to I've just merged another PR. Please
help resolve it. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the
showuon merged PR #15557:
URL: https://github.com/apache/kafka/pull/15557
--
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 code in PR #15557:
URL: https://github.com/apache/kafka/pull/15557#discussion_r1559170927
##
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala:
##
@@ -96,57 +97,55 @@ class ReplicaAlterLogDirsThread(name: String,
}
override def
showuon commented on PR #15557:
URL: https://github.com/apache/kafka/pull/15557#issuecomment-2047083295
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
showuon commented on PR #15522:
URL: https://github.com/apache/kafka/pull/15522#issuecomment-2047072476
Sorry, forgot about this PR. The jdk8 job failed to complete due to infra's
issue. Re-triggering now:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-15522/6/
--
This is an
vamossagar12 commented on PR #15594:
URL: https://github.com/apache/kafka/pull/15594#issuecomment-2047030266
@lucasbru , that test did pass. However, let me try again with the snippet
you shared above and see if it works. Let me get back to you.
--
This is an automated message from the
lucasbru merged PR #15688:
URL: https://github.com/apache/kafka/pull/15688
--
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:
soarez commented on PR #15136:
URL: https://github.com/apache/kafka/pull/15136#issuecomment-2046971782
@showuon PTAL
--
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
Damien Gasparina created KAFKA-16505:
Summary: KIP-1034: Dead letter queue in Kafka Streams
Key: KAFKA-16505
URL: https://issues.apache.org/jira/browse/KAFKA-16505
Project: Kafka
Issue
lucasbru commented on PR #15594:
URL: https://github.com/apache/kafka/pull/15594#issuecomment-2046963651
@vamossagar12 did the test you ran pass?
Here is an example how I run parameterized tests using a test suite file:
```
consumer_test:
-
soarez commented on PR #15522:
URL: https://github.com/apache/kafka/pull/15522#issuecomment-2046961029
Failing tests are all unrelated and tracked:
*
kafka.api.DelegationTokenEndToEndAuthorizationWithOwnerTest."testNoConsumeWithDescribeAclViaAssign(String).quorum=kraft"
[
https://issues.apache.org/jira/browse/KAFKA-8250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835654#comment-17835654
]
Igor Soarez commented on KAFKA-8250:
This failed again in
[
https://issues.apache.org/jira/browse/KAFKA-15793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835653#comment-17835653
]
Igor Soarez edited comment on KAFKA-15793 at 4/10/24 8:56 AM:
--
This has
dajac commented on code in PR #15662:
URL: https://github.com/apache/kafka/pull/15662#discussion_r1559052702
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -761,6 +776,58 @@ public ClassicGroup classicGroup(
}
lucasbru commented on code in PR #15661:
URL: https://github.com/apache/kafka/pull/15661#discussion_r1559094045
##
tests/kafkatest/services/verifiable_consumer.py:
##
@@ -135,6 +135,28 @@ def last_commit(self, tp):
else:
return None
+# This needs to be
[ https://issues.apache.org/jira/browse/KAFKA-15793 ]
Igor Soarez deleted comment on KAFKA-15793:
-
was (Author: soarez):
This has come up again:
{code:java}
[2024-04-09T21:06:17.307Z] Gradle Test Run :core:test > Gradle Test Executor 97
>
[
https://issues.apache.org/jira/browse/KAFKA-15793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez reopened KAFKA-15793:
-
This has come up again:
{code:java}
[2024-04-09T21:06:17.307Z] Gradle Test Run :core:test >
1 - 100 of 117 matches
Mail list logo
