lucasbru commented on PR #12760:
URL: https://github.com/apache/kafka/pull/12760#issuecomment-1290109943
System test run
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/5183
Only failure is unrelated
kafkatest.tests.core.round_trip_fault_test.RoundTripFaultTe
sudeshwasnik opened a new pull request, #12784:
URL: https://github.com/apache/kafka/pull/12784
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of te
shekhar-rajak commented on code in PR #12777:
URL: https://github.com/apache/kafka/pull/12777#discussion_r1004126495
##
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedWindowStoreTest.java:
##
@@ -1166,58 +1164,47 @@ public void
shouldNotThrowInvalidBa
omkreddy opened a new pull request, #12785:
URL: https://github.com/apache/kafka/pull/12785
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testin
omkreddy opened a new pull request, #12786:
URL: https://github.com/apache/kafka/pull/12786
Currently we are setting non-existing verbose field of Rat task. Fixed the
issue by calling correct Rat task method.
--
This is an automated message from the Apache Git Service.
To respond to the m
dajac commented on code in PR #12783:
URL: https://github.com/apache/kafka/pull/12783#discussion_r1004162782
##
core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala:
##
@@ -0,0 +1,106 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) und
lucasbru commented on code in PR #12771:
URL: https://github.com/apache/kafka/pull/12771#discussion_r1004177386
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -1435,6 +1435,31 @@ public void
shouldRethrowTaskCorruptedExceptionF
[
https://issues.apache.org/jira/browse/KAFKA-14331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass resolved KAFKA-14331.
-
Resolution: Duplicate
> Upgrade to Scala 2.13.10
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623677#comment-17623677
]
Viktor Somogyi-Vass commented on KAFKA-14331:
-
Thanks [~mimaison], I'll reso
lucasbru commented on code in PR #12771:
URL: https://github.com/apache/kafka/pull/12771#discussion_r1004217492
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -810,10 +810,19 @@ private void transitRestoredTaskToRunning(final Task t
omkreddy merged PR #12786:
URL: https://github.com/apache/kafka/pull/12786
--
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
omkreddy closed pull request #12785: Test PR
URL: https://github.com/apache/kafka/pull/12785
--
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
omkreddy commented on PR #12675:
URL: https://github.com/apache/kafka/pull/12675#issuecomment-1290366042
@mdedetrich Thanks for the PR. I have run this PR with rat verbose [output
bug fix ](https://github.com/apache/kafka/pull/12786)
Results are (https://github.com/apache/kafka/pull/
mdedetrich commented on code in PR #12728:
URL: https://github.com/apache/kafka/pull/12728#discussion_r1004412949
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -218,43 +229,37 @@ public void testCreateConnectorAlrea
mdedetrich commented on code in PR #12728:
URL: https://github.com/apache/kafka/pull/12728#discussion_r1004423779
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -319,35 +318,28 @@ public void testRestartConnectorNewT
mdedetrich commented on code in PR #12728:
URL: https://github.com/apache/kafka/pull/12728#discussion_r1004427401
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -123,91 +134,91 @@ private enum SourceSink {
priva
vamossagar12 commented on code in PR #12561:
URL: https://github.com/apache/kafka/pull/12561#discussion_r1004454702
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java:
##
@@ -517,13 +517,13 @@ public void testTaskA
[
https://issues.apache.org/jira/browse/KAFKA-14329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623818#comment-17623818
]
Deng Ziming commented on KAFKA-14329:
-
[~shizhenzhen] I think you submit your PR dir
omkreddy merged PR #12779:
URL: https://github.com/apache/kafka/pull/12779
--
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
mdedetrich commented on code in PR #12728:
URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -123,91 +134,91 @@ private enum SourceSink {
priva
mdedetrich commented on code in PR #12728:
URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -123,91 +134,91 @@ private enum SourceSink {
priva
mdedetrich commented on code in PR #12728:
URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -123,91 +134,91 @@ private enum SourceSink {
priva
mdedetrich commented on code in PR #12728:
URL: https://github.com/apache/kafka/pull/12728#discussion_r1004507344
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -123,91 +134,91 @@ private enum SourceSink {
priva
[
https://issues.apache.org/jira/browse/KAFKA-10523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623898#comment-17623898
]
Francesco Guardiani commented on KAFKA-10523:
-
I opened a similar issue in l
[
https://issues.apache.org/jira/browse/KAFKA-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-14256:
-
Assignee: Matthew de Detrich
> Update to Scala 2.13.9
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623902#comment-17623902
]
Till Rohrmann commented on KAFKA-10523:
---
Being able to provide the producer ID and
philipnee commented on code in PR #12775:
URL: https://github.com/apache/kafka/pull/12775#discussion_r1004687696
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -64,27 +64,6 @@ public class DefaultBackgroundThread extends
[
https://issues.apache.org/jira/browse/KAFKA-12199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623917#comment-17623917
]
jackwangcs commented on KAFKA-12199:
Hi [~chia7712] , are you still working on this?
dajac commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004739130
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -2236,6 +2236,30 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
ass
philipnee commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004752898
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -996,20 +1010,21 @@ private void ensureTransactional() {
}
vvcephei commented on PR #12775:
URL: https://github.com/apache/kafka/pull/12775#issuecomment-1290934035
I don't see how it could be related, but Gradle got a bunch of OOMEs on your
last test run, so I kicked it off again.
--
This is an automated message from the Apache Git Service.
To re
scott-hendricks closed pull request #7487: KAFKA-9010: Add PartitionGrower,
Support partition requery in ProduceBench test.
URL: https://github.com/apache/kafka/pull/7487
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
functioner commented on PR #11520:
URL: https://github.com/apache/kafka/pull/11520#issuecomment-1290981297
I have updated the patch. It seems `LogDirFailureChannel` requires some
`logDir` to use, which is absent here and I currently I don't have idea about
this. @hachikuji What do you thin
gharris1727 commented on code in PR #12781:
URL: https://github.com/apache/kafka/pull/12781#discussion_r1004923625
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java:
##
@@ -547,32 +540,22 @@ public void
testReadEndOffsetsUsingAdminThatFailsWi
[
https://issues.apache.org/jira/browse/KAFKA-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624027#comment-17624027
]
Richard Joerger commented on KAFKA-14326:
-
[~mallwoodrbi], would you be able to
Moovlin opened a new pull request, #12787:
URL: https://github.com/apache/kafka/pull/12787
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
The goal of the change
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004941219
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -618,7 +618,8 @@ private TransactionManager
configureTransactionState(ProducerConf
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004941219
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -618,7 +618,8 @@ private TransactionManager
configureTransactionState(ProducerConf
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004944699
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -618,7 +618,8 @@ private TransactionManager
configureTransactionState(ProducerConf
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004948547
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -155,7 +155,7 @@ private enum State {
private boolean isTra
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004948547
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -155,7 +155,7 @@ private enum State {
private boolean isTra
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004955636
##
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java:
##
@@ -1237,6 +1238,34 @@ public void testInitTransactionWhileThrottled() {
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1004958467
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -2236,6 +2236,30 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
a
gharris1727 commented on code in PR #12544:
URL: https://github.com/apache/kafka/pull/12544#discussion_r1004961482
##
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java:
##
@@ -106,6 +108,7 @@ public Connect startConnect(Map
workerProps) {
[
https://issues.apache.org/jira/browse/KAFKA-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624052#comment-17624052
]
Greg Harris commented on KAFKA-14023:
-
[~Justinwins] I believe the motivation for th
[
https://issues.apache.org/jira/browse/KAFKA-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-14023.
-
Resolution: Won't Do
> MirrorCheckpointTask.syncGroupOffset does not have to check if translate
philipnee opened a new pull request, #12788:
URL: https://github.com/apache/kafka/pull/12788
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testi
gharris1727 opened a new pull request, #12789:
URL: https://github.com/apache/kafka/pull/12789
Signed-off-by: Greg Harris
https://issues.apache.org/jira/browse/KAFKA-13989
This method is used by the REST API in the `GET
/connectors?expand=info,status` call.
In cases where a
[
https://issues.apache.org/jira/browse/KAFKA-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624070#comment-17624070
]
Matt Allwood commented on KAFKA-14326:
--
Pretty much, just our app is a bit of a beh
soarez commented on code in PR #12789:
URL: https://github.com/apache/kafka/pull/12789#discussion_r1005027030
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -691,7 +691,14 @@ protected Connector getConnector(String connType) {
C0urante commented on code in PR #12544:
URL: https://github.com/apache/kafka/pull/12544#discussion_r1005090102
##
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java:
##
@@ -106,6 +108,7 @@ public Connect startConnect(Map
workerProps) {
thanhnd96 created KAFKA-14337:
-
Summary: bugs kafka 3.3.1 create topic after delete topic
Key: KAFKA-14337
URL: https://issues.apache.org/jira/browse/KAFKA-14337
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-14337:
-
Assignee: Luke Chen
> bugs kafka 3.3.1 create topic after delete topic
> --
[
https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624189#comment-17624189
]
Luke Chen commented on KAFKA-14337:
---
Nice find! Investigating!
> bugs kafka 3.3.1
[
https://issues.apache.org/jira/browse/KAFKA-14324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
VZhang updated KAFKA-14324:
---
Attachment: 6.29.4.1_to_7.1.2_compat_report.html
> [CVE-2018-25032] introduced by rocksdbjni:6.29.4.1
>
[
https://issues.apache.org/jira/browse/KAFKA-14324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
VZhang updated KAFKA-14324:
---
Attachment: 6.29.4.1_to_7.7.3_compat_report.html
> [CVE-2018-25032] introduced by rocksdbjni:6.29.4.1
>
[
https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
thanhnd96 updated KAFKA-14337:
--
Description:
Hi admin,
My issue is after i create topic like topic.AAA or Topic.AAA.01 then delete 1
57 matches
Mail list logo