hachikuji commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r571362924
##
File path: core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
##
@@ -169,6 +169,8 @@ class DefaultAutoTopicCreationManager(
}
showuon commented on pull request #10002:
URL: https://github.com/apache/kafka/pull/10002#issuecomment-774401866
@omkreddy , thanks for comments. I've updated.
This is an automated message from the Apache Git Service.
To
showuon commented on a change in pull request #10002:
URL: https://github.com/apache/kafka/pull/10002#discussion_r571361102
##
File path: docs/security.html
##
@@ -649,22 +649,22 @@ Configuring Kafka Brokers
Add a suitably modified JAAS file similar
C0urante opened a new pull request #10074:
URL: https://github.com/apache/kafka/pull/10074
[Jira](https://issues.apache.org/jira/browse/KAFKA-12305)
(Copied from Jira):
The `Flatten` SMT fails for array types. A sophisticated approach that tries
to flatten arrays might be
[
https://issues.apache.org/jira/browse/KAFKA-12305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-12305:
--
Description:
The {{Flatten}} SMT fails for array types. A sophisticated approach that tries
Chris Egerton created KAFKA-12305:
-
Summary: Flatten SMT fails on arrays
Key: KAFKA-12305
URL: https://issues.apache.org/jira/browse/KAFKA-12305
Project: Kafka
Issue Type: Bug
C0urante opened a new pull request #10073:
URL: https://github.com/apache/kafka/pull/10073
[Jira](https://issues.apache.org/jira/browse/KAFKA-12303)
Using `return` instead of `continue` when encountering null fields causes
the remainder of the fields to be skipped. This PR addresses
Boyang Chen created KAFKA-12304:
---
Summary: Improve topic validation in auto topic creation
Key: KAFKA-12304
URL: https://issues.apache.org/jira/browse/KAFKA-12304
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-12303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-12303:
--
Summary: Flatten SMT drops some fields when null values are present (was:
Flatten SMT drops
Chris Egerton created KAFKA-12303:
-
Summary: Flatten SMT drops some nested fields
Key: KAFKA-12303
URL: https://issues.apache.org/jira/browse/KAFKA-12303
Project: Kafka
Issue Type: Bug
mjsax merged pull request #1:
URL: https://github.com/apache/kafka/pull/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
mjsax commented on a change in pull request #10072:
URL: https://github.com/apache/kafka/pull/10072#discussion_r571331549
##
File path: streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
##
@@ -32,6 +33,7 @@
public final int topicGroupId;
/** The ID
cmccabe merged pull request #10049:
URL: https://github.com/apache/kafka/pull/10049
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
ableegoldman commented on a change in pull request #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r571317298
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -229,17 +231,22 @@ public void
ableegoldman commented on a change in pull request #10072:
URL: https://github.com/apache/kafka/pull/10072#discussion_r571317046
##
File path: streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
##
@@ -32,6 +33,7 @@
public final int topicGroupId;
/**
[
https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280044#comment-17280044
]
Matthias J. Sax commented on KAFKA-12213:
-
Works for me. Just wanted to point out, that
mjsax opened a new pull request #10072:
URL: https://github.com/apache/kafka/pull/10072
Part of KIP-572: follow up work to PR #9800. It's not save to retry a TX
commit after a timeout, because it's unclear if the commit was
successful or not, and thus on retry we might get an
rondagostino commented on a change in pull request #10069:
URL: https://github.com/apache/kafka/pull/10069#discussion_r571309365
##
File path: core/src/main/scala/kafka/server/RaftReplicaManager.scala
##
@@ -0,0 +1,538 @@
+/**
+ * Licensed to the Apache Software Foundation
rondagostino commented on a change in pull request #10069:
URL: https://github.com/apache/kafka/pull/10069#discussion_r571237871
##
File path: core/src/main/scala/kafka/server/RaftReplicaManager.scala
##
@@ -0,0 +1,538 @@
+/**
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9195:
--
Assignee: Matthias J. Sax
> Use Randomized State Directory Names in Streams System
[
https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280034#comment-17280034
]
Piotr Fras edited comment on KAFKA-12213 at 2/5/21, 11:09 PM:
--
I am going
[
https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280034#comment-17280034
]
Piotr Fras commented on KAFKA-12213:
I am going to break down KIP-149 into five streams of work and
[
https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280034#comment-17280034
]
Piotr Fras edited comment on KAFKA-12213 at 2/5/21, 11:02 PM:
--
I am going
[
https://issues.apache.org/jira/browse/KAFKA-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-10678.
Assignee: A. Sophie Blee-Goldman
Resolution: Fixed
Resolved via
[
https://issues.apache.org/jira/browse/KAFKA-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10678:
---
Fix Version/s: 2.6.2
2.7.1
2.8.0
>
[
https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280030#comment-17280030
]
Matthias J. Sax commented on KAFKA-12213:
-
It's totally fine to implement it incrementally
[
https://issues.apache.org/jira/browse/KAFKA-12288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12288:
Component/s: streams
> Remove task-level filesystem locks
>
hachikuji commented on pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#issuecomment-774326674
@abbccdda Thanks for the updates. I opened a PR with a few fixes to speed
this along since we're trying to get it checked in today:
https://github.com/abbccdda/kafka/pull/6.
rondagostino commented on a change in pull request #10039:
URL: https://github.com/apache/kafka/pull/10039#discussion_r571283864
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -352,13 +348,15 @@ class LogManager(logDirs: Seq[File],
val
rondagostino commented on a change in pull request #10039:
URL: https://github.com/apache/kafka/pull/10039#discussion_r571283864
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -352,13 +348,15 @@ class LogManager(logDirs: Seq[File],
val
rondagostino commented on a change in pull request #10039:
URL: https://github.com/apache/kafka/pull/10039#discussion_r571278884
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -352,13 +348,15 @@ class LogManager(logDirs: Seq[File],
val
rondagostino commented on a change in pull request #10039:
URL: https://github.com/apache/kafka/pull/10039#discussion_r571276941
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -403,7 +401,30 @@ class LogManager(logDirs: Seq[File],
/**
* Start the
rondagostino commented on a change in pull request #10039:
URL: https://github.com/apache/kafka/pull/10039#discussion_r571275654
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -403,7 +401,30 @@ class LogManager(logDirs: Seq[File],
/**
* Start the
rondagostino commented on a change in pull request #10039:
URL: https://github.com/apache/kafka/pull/10039#discussion_r571274481
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -403,7 +401,30 @@ class LogManager(logDirs: Seq[File],
/**
* Start the
mumrah commented on a change in pull request #10039:
URL: https://github.com/apache/kafka/pull/10039#discussion_r571268386
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -403,7 +401,30 @@ class LogManager(logDirs: Seq[File],
/**
* Start the
Matthias J. Sax created KAFKA-12302:
---
Summary: Flaky Test
SaslApiVersionsRequestTest#testApiVersionsRequestWithUnsupportedVersion
Key: KAFKA-12302
URL: https://issues.apache.org/jira/browse/KAFKA-12302
[
https://issues.apache.org/jira/browse/KAFKA-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280008#comment-17280008
]
Matthias J. Sax commented on KAFKA-12284:
-
Failed again:
mumrah commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571258754
##
File path: core/src/test/java/kafka/test/ClusterInstance.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
ijuma commented on a change in pull request #10069:
URL: https://github.com/apache/kafka/pull/10069#discussion_r571257684
##
File path: core/src/main/scala/kafka/server/DelayedDeleteRecords.scala
##
@@ -84,7 +84,7 @@ class DelayedDeleteRecords(delayMs: Long,
mumrah commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571257075
##
File path: core/src/test/java/kafka/test/ClusterInstance.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571253465
##
File path: core/src/main/scala/kafka/server/metadata/RaftMetadataCache.scala
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1727#comment-1727
]
Matthias J. Sax commented on KAFKA-9527:
Thanks everyone. I'll try to review the PR soon – but we
cmccabe commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571246502
##
File path: core/src/test/java/kafka/test/ClusterInstance.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
hachikuji merged pull request #10045:
URL: https://github.com/apache/kafka/pull/10045
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
cmccabe commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571245971
##
File path: core/src/test/java/kafka/test/ClusterInstance.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
Jeremy Custenborder created KAFKA-12301:
---
Summary: Support for enum validation in configuration
Key: KAFKA-12301
URL: https://issues.apache.org/jira/browse/KAFKA-12301
Project: Kafka
cmccabe commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571245403
##
File path: core/src/test/java/kafka/test/ClusterInstance.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
jolshan opened a new pull request #10071:
URL: https://github.com/apache/kafka/pull/10071
I thought it would be useful to check how the changes to
LeaderAndIsrRequests (for KIP-516) affect the handling of the request. This
benchmark builds a LeaderAndIsrRequest and calls
cmccabe commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571244427
##
File path: core/src/test/java/kafka/test/ClusterInstance.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
cmccabe commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571242927
##
File path: core/src/test/java/kafka/test/ClusterConfig.java
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
cmccabe commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571241978
##
File path: core/src/test/java/kafka/test/annotation/Type.java
##
@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
https://issues.apache.org/jira/browse/KAFKA-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman closed KAFKA-10716.
--
> Streams processId is unstable across restarts resulting in task mass migration
ableegoldman commented on pull request #10060:
URL: https://github.com/apache/kafka/pull/10060#issuecomment-774266721
Merged to 2.7 and cherrypicked to 2.6
This is an automated message from the Apache Git Service.
To respond
cmccabe commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571208259
##
File path: core/src/main/scala/kafka/server/metadata/MetadataBrokers.scala
##
@@ -37,7 +36,15 @@ object MetadataBroker {
endPoint.name() ->
alex wang created KAFKA-12300:
-
Summary: Log source broker when handling metadata response
Key: KAFKA-12300
URL: https://issues.apache.org/jira/browse/KAFKA-12300
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279941#comment-17279941
]
jbfletch commented on KAFKA-9527:
-
Thanks for taking this on [~marcolotz]
> Application Reset Tool
ableegoldman merged pull request #10060:
URL: https://github.com/apache/kafka/pull/10060
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
[
https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12279.
Resolution: Not A Bug
> Kafka 2.7 stream app issue
>
[
https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279938#comment-17279938
]
A. Sophie Blee-Goldman commented on KAFKA-12279:
Root cause: the source topic was
rondagostino commented on a change in pull request #10045:
URL: https://github.com/apache/kafka/pull/10045#discussion_r571174825
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3511,4 +3501,14 @@ object KafkaApis {
FetchResponse.sizeOf(versionId,
hachikuji commented on a change in pull request #10045:
URL: https://github.com/apache/kafka/pull/10045#discussion_r571174163
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3511,4 +3501,14 @@ object KafkaApis {
FetchResponse.sizeOf(versionId,
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571173703
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
[
https://issues.apache.org/jira/browse/KAFKA-12299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-12299:
-
Description:
When merging the Raft MetadataCache changes for 2.8, we identified a few follow
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571173506
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
David Arthur created KAFKA-12299:
Summary: Follow ups from MetadataCache changes
Key: KAFKA-12299
URL: https://issues.apache.org/jira/browse/KAFKA-12299
Project: Kafka
Issue Type: Task
cmccabe opened a new pull request #10070:
URL: https://github.com/apache/kafka/pull/10070
The quorum controller stores metadata in the KIP-500 metadata log, not in
Apache ZooKeeper. Each controller node is a voter in the metadata quorum. The
leader of the quorum is the active
hachikuji commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571169638
##
File path: core/src/main/scala/kafka/server/metadata/RaftMetadataCache.scala
##
@@ -0,0 +1,389 @@
+/*
+ * Licensed to the Apache Software Foundation
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571163776
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -485,7 +494,7 @@ class MetadataCacheTest {
@Test
Review comment:
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571163226
##
File path: core/src/main/scala/kafka/server/metadata/MetadataBrokers.scala
##
@@ -37,7 +36,15 @@ object MetadataBroker {
endPoint.name() ->
hachikuji commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571162641
##
File path: core/src/main/scala/kafka/server/metadata/RaftMetadataCache.scala
##
@@ -0,0 +1,389 @@
+/*
+ * Licensed to the Apache Software Foundation
hachikuji commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571151499
##
File path: core/src/main/scala/kafka/server/metadata/MetadataImage.scala
##
@@ -118,5 +118,10 @@ case class MetadataImage(partitions:
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571161027
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -16,20 +16,20 @@
*/
package kafka.server
+import
hachikuji commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571149211
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
hachikuji commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571148172
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -16,20 +16,20 @@
*/
package kafka.server
+import
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571145320
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
hachikuji commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571142951
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571140218
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571139784
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
hachikuji commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571139392
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571138962
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -16,20 +16,20 @@
*/
package kafka.server
+import
omkreddy commented on a change in pull request #10002:
URL: https://github.com/apache/kafka/pull/10002#discussion_r571127207
##
File path: docs/security.html
##
@@ -649,22 +649,22 @@ Configuring Kafka Brokers
Add a suitably modified JAAS file similar
rondagostino commented on a change in pull request #10045:
URL: https://github.com/apache/kafka/pull/10045#discussion_r571124965
##
File path: core/src/main/scala/kafka/server/MetadataSupport.scala
##
@@ -0,0 +1,109 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
mumrah commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r571122210
##
File path:
core/src/test/scala/unit/kafka/server/SaslApiVersionsRequestTest.scala
##
@@ -16,83 +16,94 @@
*/
package kafka.server
+import
cmccabe commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571119868
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -16,20 +16,20 @@
*/
package kafka.server
+import
cmccabe commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571118214
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
cmccabe commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571116863
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
cmccabe commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r571116386
##
File path: core/src/main/scala/kafka/server/MetadataCache.scala
##
@@ -34,16 +34,69 @@ import
cmccabe merged pull request #10008:
URL: https://github.com/apache/kafka/pull/10008
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
chia7712 closed pull request #10050:
URL: https://github.com/apache/kafka/pull/10050
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 pull request #10050:
URL: https://github.com/apache/kafka/pull/10050#issuecomment-774149259
@mumrah Thanks for kind reminder. close this now.
This is an automated message from the Apache Git Service.
To
Justine Olshan created KAFKA-12298:
--
Summary: Create LeaderAndIsrRequestBenchmark
Key: KAFKA-12298
URL: https://issues.apache.org/jira/browse/KAFKA-12298
Project: Kafka
Issue Type: Task
rondagostino opened a new pull request #10069:
URL: https://github.com/apache/kafka/pull/10069
This adds the logic to apply partition metadata when consuming from the
Raft-based metadata log.
`RaftReplicaManager` extends `ReplicaManager` for now to minimize changes to
existing code
dajac commented on pull request #10068:
URL: https://github.com/apache/kafka/pull/10068#issuecomment-774140916
I've re-triggered Jenkins. I will merge once we have a clean run.
This is an automated message from the Apache
cmccabe commented on pull request #10008:
URL: https://github.com/apache/kafka/pull/10008#issuecomment-774136720
Failing tests are
`org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest.testMultipleWorkersRejoining`
and
[
https://issues.apache.org/jira/browse/KAFKA-12193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-12193:
Fix Version/s: 2.6.2
> Re-resolve IPs when a client is disconnected
>
dajac commented on pull request #10061:
URL: https://github.com/apache/kafka/pull/10061#issuecomment-774097673
@ableegoldman FYI - We have backported this fix to 2.6.
This is an automated message from the Apache Git Service.
dajac merged pull request #10061:
URL: https://github.com/apache/kafka/pull/10061
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
[
https://issues.apache.org/jira/browse/KAFKA-12274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michał Łukowicz updated KAFKA-12274:
Description:
Hello Team!
One of our clusters is being used to:
* process transactional
mumrah commented on pull request #10050:
URL: https://github.com/apache/kafka/pull/10050#issuecomment-774082101
@chia7712 I think this got fixed yesterday on trunk with the addition of a
new HostResolver interface. Now we can precisely control what IPs are resolved
during testing.
dajac commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r571004759
##
File path: core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
1 - 100 of 201 matches
Mail list logo
