ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r781827295
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -436,9 +436,25 @@ public String
A. Sophie Blee-Goldman created KAFKA-13590:
--
Summary: Rename InternalTopologyBuilder's #topicGroups method to
be more descriptive
Key: KAFKA-13590
URL: https://issues.apache.org/jira/browse/KAFKA-13590
ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r781821011
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -436,9 +436,25 @@ public String
ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r781818108
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -380,15 +380,37 @@ public
ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r781817617
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -1137,6 +1138,8 @@ private void
ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r781814872
##
File path: checkstyle/suppressions.xml
##
@@ -158,7 +158,7 @@
mdshadabin edited a comment on pull request #10056:
URL: https://github.com/apache/kafka/pull/10056#issuecomment-1009656742
Thanks @ewencp ,
I have switched to Kafka 3.0.0, i always see a few unit test failures.
Download Kafka source code from official side and follow git hub to
mdshadabin commented on pull request #10056:
URL: https://github.com/apache/kafka/pull/10056#issuecomment-1009656742
Thanks @ewencp ,
I have switched to Kafka 3.0.0, i always see a few unit test failures.
Download Kafka source code from official side and follow git hub to build
Luke Chen created KAFKA-13589:
-
Summary: fix flaky
`PlaintextAdminIntegrationTest.testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords`
test
Key: KAFKA-13589
URL: https://issues.apache.org/jira/browse/KAFKA-13589
vlsi commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1009629904
If the only motivation for moving 1.x -> 2.x is security, then it might be
better for both Kafka and Kafka users to stick with 1.x and ask/wait/help with
releasing a hardened 1.x.
dongjinleekr commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1009624788
@vlsi
> Have you explored the possibility of resurrecting and releasing 1.x?
Not yet. KIP-653 has been started long before the log4j crisis of 2020.
--
This
[
https://issues.apache.org/jira/browse/KAFKA-10466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472465#comment-17472465
]
Ari Iramanesh commented on KAFKA-10466:
---
Hey [~daehokimm], I've sent some commits that should fix
aith commented on pull request #9259:
URL: https://github.com/apache/kafka/pull/9259#issuecomment-1009619745
Hey @daehokimm, I'm thinking that the maintainers would be more inclined to
review your PR if the build errors were resolved. I went ahead and fixed the
build errors at my [branch
[
https://issues.apache.org/jira/browse/KAFKA-10466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ari Iramanesh reassigned KAFKA-10466:
-
Assignee: Ari Iramanesh
> Add Regex option for replacement on MaskField SMT
>
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472449#comment-17472449
]
Ryan Leslie commented on KAFKA-13435:
-
Not ideal, but as a first step, is a partial solution
[
https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472424#comment-17472424
]
Eugen Dück commented on KAFKA-13289:
I (accidentally) noticed that one way to reproduce "Skipping
guozhangwang merged pull request #11611:
URL: https://github.com/apache/kafka/pull/11611
--
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-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472368#comment-17472368
]
Guozhang Wang commented on KAFKA-13588:
---
This would also include consolidating the duplicated
junrao commented on a change in pull request #11660:
URL: https://github.com/apache/kafka/pull/11660#discussion_r781655987
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -68,7 +68,7 @@ public ClusterConnectionStates(long
cmccabe commented on a change in pull request #11634:
URL: https://github.com/apache/kafka/pull/11634#discussion_r781655349
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandIntegrationTest.scala
##
@@ -443,25 +486,30 @@ class TopicCommandIntegrationTest extends
junrao commented on a change in pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#discussion_r781653267
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -1498,28 +1498,46 @@ class UnifiedLog(@volatile var logStartOffset: Long,
cmccabe commented on pull request #11636:
URL: https://github.com/apache/kafka/pull/11636#issuecomment-1009458806
I think we should replace Mockito in a separate PR. Otherwise it might be
hard to see which changes are related to that and which are related to KRaft.
--
This is an
cmccabe commented on a change in pull request #11638:
URL: https://github.com/apache/kafka/pull/11638#discussion_r781654110
##
File path:
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala
##
@@ -162,7 +162,7 @@ abstract class
cmccabe commented on pull request #11639:
URL: https://github.com/apache/kafka/pull/11639#issuecomment-1009457475
Jenkins test failure is
`FetchRequestBetweenDifferentIbpTest#testControllerOldToNewIBP`, which was not
affected by the change here.
--
This is an automated message from
cmccabe commented on a change in pull request #11606:
URL: https://github.com/apache/kafka/pull/11606#discussion_r781651984
##
File path:
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala
##
@@ -142,6 +127,19 @@ abstract class KafkaServerTestHarness
cmccabe commented on a change in pull request #11606:
URL: https://github.com/apache/kafka/pull/11606#discussion_r781651142
##
File path:
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala
##
@@ -253,4 +248,32 @@ abstract class KafkaServerTestHarness
cmccabe commented on a change in pull request #11606:
URL: https://github.com/apache/kafka/pull/11606#discussion_r781650275
##
File path: core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala
##
@@ -196,14 +199,16 @@ abstract class QuorumTestHarness extends
ccding commented on a change in pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#discussion_r781624729
##
File path: core/src/main/scala/kafka/log/LogLoader.scala
##
@@ -333,8 +333,9 @@ object LogLoader extends Logging {
try
wcarlson5 commented on pull request #11611:
URL: https://github.com/apache/kafka/pull/11611#issuecomment-1009368253
@guozhangwang Yeah I needed update a few tests. It should be good now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Walker Carlson created KAFKA-13588:
--
Summary: We should consolidate `changelogFor` methods to simplify
the generation of internal topic names
Key: KAFKA-13588
URL:
wcarlson5 commented on a change in pull request #11611:
URL: https://github.com/apache/kafka/pull/11611#discussion_r781511282
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java
##
@@ -85,8 +86,13 @@ public void init(final
junrao commented on a change in pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#discussion_r781485562
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -1498,28 +1498,44 @@ class UnifiedLog(@volatile var logStartOffset: Long,
dajac commented on pull request #11664:
URL: https://github.com/apache/kafka/pull/11664#issuecomment-1009289935
Merged to trunk and 3.1.
--
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
dajac merged pull request #11664:
URL: https://github.com/apache/kafka/pull/11664
--
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-13587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-13587:
--
Assignee: Jose Armando Garcia Sancio
> Implement unclean
Jose Armando Garcia Sancio created KAFKA-13587:
--
Summary: Implement unclean leader election in KIP-704
Key: KAFKA-13587
URL: https://issues.apache.org/jira/browse/KAFKA-13587
Project:
Greg Harris created KAFKA-13586:
---
Summary: ConfigExceptions thrown by FileConfigProvider during
connector/task startup crash worker
Key: KAFKA-13586
URL: https://issues.apache.org/jira/browse/KAFKA-13586
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472207#comment-17472207
]
Jun Rao commented on KAFKA-2729:
[~mgabriel] : The BadVersion on ZK server just indicates that a
vlsi edited a comment on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1009197651
I might be slightly late for the party, however, have you explored the
possibility of resurrecting and releasing 1.x?
I do think it is worth resurrecting 1.x and fix
vlsi commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1009197651
I might be slightly late for the party, however, have you explored the
possibility of resurrecting and releasing 1.x?
I do think it is worth resurrecting 1.x and fix the
rondagostino commented on pull request #11664:
URL: https://github.com/apache/kafka/pull/11664#issuecomment-1009152871
Ran the failing tests (plus 1 more) locally, and they all passed.
```
SESSION
rondagostino opened a new pull request #11664:
URL: https://github.com/apache/kafka/pull/11664
…ocols fails
KRaft brokers always use the first controller listener, so if there is not
also a colocated KRaft controller on the node be sure to only publish one
controller listener in
brianwyka commented on pull request #9584:
URL: https://github.com/apache/kafka/pull/9584#issuecomment-1009032105
I'm not sure @kirktrue.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472112#comment-17472112
]
Matthias Gabriel edited comment on KAFKA-2729 at 1/10/22, 3:43 PM:
---
Hey
[
https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472112#comment-17472112
]
Matthias Gabriel commented on KAFKA-2729:
-
Hey [~junrao],
We also have the same issue recurring
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472085#comment-17472085
]
David Jacot commented on KAFKA-13435:
-
Thanks, [~hachikuji]. I think that AK assignors are usually
YeonCheolGit opened a new pull request #11663:
URL: https://github.com/apache/kafka/pull/11663
### More detailed description of your change,
_(This is my first PR for Kafka as junior engineer. This suggestion might be
silly)_
If `.size()` is called when it is needed, JVM has to
[
https://issues.apache.org/jira/browse/KAFKA-12480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472044#comment-17472044
]
QCU commented on KAFKA-12480:
-
I am also troubled by this problem. Is there any progress on this problem？
>
[
https://issues.apache.org/jira/browse/KAFKA-13582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472026#comment-17472026
]
David Jacot commented on KAFKA-13582:
-
I have reduced the priority to Major as it is purely a
[
https://issues.apache.org/jira/browse/KAFKA-13582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13582:
Priority: Major (was: Blocker)
> `TestVerifiableProducer.
[
https://issues.apache.org/jira/browse/KAFKA-13582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-13582:
---
Assignee: Ron Dagostino
> `TestVerifiableProducer. test_multiple_kraft_security_protocols`
[
https://issues.apache.org/jira/browse/KAFKA-13582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472008#comment-17472008
]
Ron Dagostino commented on KAFKA-13582:
---
This is purely a test configuration issue. An example
David Jacot created KAFKA-13585:
---
Summary: Fix
`kafka.server.ReplicaManagerTest.testReplicaAlterLogDirsWithAndWithoutIds`
flaky test
Key: KAFKA-13585
URL: https://issues.apache.org/jira/browse/KAFKA-13585
David Jacot created KAFKA-13584:
---
Summary: Fix
`kafka.network.SocketServerTest.testUnmuteChannelWithBufferedReceives` flaky
test
Key: KAFKA-13584
URL: https://issues.apache.org/jira/browse/KAFKA-13584
[
https://issues.apache.org/jira/browse/KAFKA-13583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13583:
Description:
FetchRequestBetweenDifferentIbpTest's tests often fails with:
{noformat}
David Jacot created KAFKA-13583:
---
Summary: Fix FetchRequestBetweenDifferentIbpTest flaky tests
Key: KAFKA-13583
URL: https://issues.apache.org/jira/browse/KAFKA-13583
Project: Kafka
Issue
viktorsomogyi closed pull request #9152:
URL: https://github.com/apache/kafka/pull/9152
--
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:
viktorsomogyi closed pull request #9151:
URL: https://github.com/apache/kafka/pull/9151
--
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:
viktorsomogyi closed pull request #9150:
URL: https://github.com/apache/kafka/pull/9150
--
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-13582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13582:
Description:
`TestVerifiableProducer. test_multiple_kraft_security_protocols` consistently
fails
David Jacot created KAFKA-13582:
---
Summary: `TestVerifiableProducer.
test_multiple_kraft_security_protocols` consistently fails
Key: KAFKA-13582
URL: https://issues.apache.org/jira/browse/KAFKA-13582
[
https://issues.apache.org/jira/browse/KAFKA-13312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-13312.
-
Resolution: Fixed
> 'NetworkDegradeTest#test_rate' should wait until iperf server is listening
[
https://issues.apache.org/jira/browse/KAFKA-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-10712.
-
Fix Version/s: 3.1.0
Resolution: Fixed
> Update release scripts to Python3
>
63 matches
Mail list logo
