satishd merged PR #13079:
URL: https://github.com/apache/kafka/pull/13079
--
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:
satishd commented on PR #13079:
URL: https://github.com/apache/kafka/pull/13079#issuecomment-1371882997
These intermittent test failures are not related to this change, merging it
to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
iamazy commented on PR #13072:
URL: https://github.com/apache/kafka/pull/13072#issuecomment-1371872165
@ijuma please take a look.
--
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
dengziming closed pull request #10467: KAFKA-12609: Rewrite ListOffsets using
AdminApiDriver
URL: https://github.com/apache/kafka/pull/10467
--
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
dengziming closed pull request #10147: MINOR: Add raft resigned state metric
name
URL: https://github.com/apache/kafka/pull/10147
--
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
dengziming closed pull request #9500: Investigate Flaky tests
URL: https://github.com/apache/kafka/pull/9500
--
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,
Naancy commented on code in PR #12462:
URL: https://github.com/apache/kafka/pull/12462#discussion_r1062120831
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -273,26 +273,29 @@ public RecordAppendResult append(String topic,
ijuma commented on code in PR #13046:
URL: https://github.com/apache/kafka/pull/13046#discussion_r1062119225
##
storage/src/main/java/org/apache/kafka/server/log/internals/LeaderEpochCheckpoint.java:
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
ijuma commented on code in PR #13046:
URL: https://github.com/apache/kafka/pull/13046#discussion_r1062119225
##
storage/src/main/java/org/apache/kafka/server/log/internals/LeaderEpochCheckpoint.java:
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
ijuma commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1062116212
##
server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java:
##
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache Software Foundation
satishd commented on PR #13043:
URL: https://github.com/apache/kafka/pull/13043#issuecomment-1371789074
@ijuma I rebased it with trunk to resolve the conflicts, working on
addressing your review comments. I will let you once I am done with my changes.
--
This is an automated message
satishd commented on PR #13079:
URL: https://github.com/apache/kafka/pull/13079#issuecomment-1371756473
@ijuma: Filed https://issues.apache.org/jira/browse/KAFKA-14574 as you
suggested.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Satish Duggana created KAFKA-14574:
--
Summary: Add doc generation as part of the CI build process
Key: KAFKA-14574
URL: https://issues.apache.org/jira/browse/KAFKA-14574
Project: Kafka
Issue
satishd merged PR #13065:
URL: https://github.com/apache/kafka/pull/13065
--
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:
satishd commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1062049275
##
storage/src/main/java/org/apache/kafka/server/log/internals/LogConfig.java:
##
@@ -0,0 +1,504 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
satishd commented on PR #13065:
URL: https://github.com/apache/kafka/pull/13065#issuecomment-1371669507
Failing test does not seem to be related to this change.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ijuma commented on PR #13079:
URL: https://github.com/apache/kafka/pull/13079#issuecomment-1371663717
We should ideally run this as part of the CI build. Maybe file a JIRA for it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
junrao commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1062032815
##
server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java:
##
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache Software Foundation
satishd commented on PR #13079:
URL: https://github.com/apache/kafka/pull/13079#issuecomment-1371638327
cc @ijuma @showuon @omkreddy
--
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
satishd opened a new pull request, #13079:
URL: https://github.com/apache/kafka/pull/13079
MINOR Fixed doc generation for LogConfig class in genTopicConfigDocs.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
jolshan commented on PR #13078:
URL: https://github.com/apache/kafka/pull/13078#issuecomment-1371634002
Thanks @anatasiavela and @artemlivshits -- I'll take a look at the build
when it completes, but this looks pretty good so far.
--
This is an automated message from the Apache Git
jolshan commented on code in PR #13068:
URL: https://github.com/apache/kafka/pull/13068#discussion_r1062016540
##
core/src/main/scala/kafka/log/ProducerStateManager.scala:
##
@@ -502,6 +503,8 @@ class ProducerStateManager(
private var lastMapOffset = 0L
private var
jolshan commented on PR #13068:
URL: https://github.com/apache/kafka/pull/13068#issuecomment-1371625876
Here's the alternative PR: https://github.com/apache/kafka/pull/13078
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
cmccabe closed pull request #13028: KAFKA-14458: Introduce RPC support during
ZK migration
URL: https://github.com/apache/kafka/pull/13028
--
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
cmccabe commented on PR #13028:
URL: https://github.com/apache/kafka/pull/13028#issuecomment-1371610742
LGTM
committed
--
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
anatasiavela opened a new pull request, #13078:
URL: https://github.com/apache/kafka/pull/13078
This is the PR for the implementation of KIP-847:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-847%3A+Add+ProducerIdCount+metrics
Add ProducerIdCount metric at the broker level:
ijuma commented on PR #13075:
URL: https://github.com/apache/kafka/pull/13075#issuecomment-1371558425
Is it possible to add a test?
--
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
ijuma commented on PR #13073:
URL: https://github.com/apache/kafka/pull/13073#issuecomment-1371550279
Merged to trunk, 3.4 and 3.3.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-14571.
-
Resolution: Fixed
> ZkMetadataCache.getClusterMetadata is missing rack information in
mjsax commented on code in PR #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r1061951302
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java:
##
@@ -24,8 +24,6 @@
public class ChangedDeserializer implements
jsancio commented on PR #13058:
URL: https://github.com/apache/kafka/pull/13058#issuecomment-1371500365
I should mention that the long term solution would be to extend the
LogManager to support the kraft metadata log but there are issues like
ijuma merged PR #13073:
URL: https://github.com/apache/kafka/pull/13073
--
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:
ijuma commented on PR #13073:
URL: https://github.com/apache/kafka/pull/13073#issuecomment-1371494418
I see, makes sense. 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 to the specific
jsancio commented on code in PR #13058:
URL: https://github.com/apache/kafka/pull/13058#discussion_r1061930398
##
core/src/main/scala/kafka/raft/RaftManager.scala:
##
@@ -154,6 +192,8 @@ class KafkaRaftManager[T](
scheduler.shutdown()
netChannel.close()
[
https://issues.apache.org/jira/browse/KAFKA-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654663#comment-17654663
]
Edoardo Comar commented on KAFKA-14571:
---
classified as minor because the the Cluster object
jsancio commented on code in PR #13058:
URL: https://github.com/apache/kafka/pull/13058#discussion_r1061928077
##
core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala:
##
@@ -81,25 +100,99 @@ class RaftManagerTest {
)
}
- @Test
- def
[
https://issues.apache.org/jira/browse/KAFKA-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-14571:
--
Priority: Minor (was: Major)
> ZkMetadataCache.getClusterMetadata is missing rack
edoardocomar commented on PR #13073:
URL: https://github.com/apache/kafka/pull/13073#issuecomment-1371482567
@ijuma
the `Cluster` object returned from `MetadataCache.getClusterMetadata(...)`
is passed to `ClientQuotaCallback.updateClusterMetadata(...)`
so I'd say it is used,
ijuma commented on code in PR #12210:
URL: https://github.com/apache/kafka/pull/12210#discussion_r1061872501
##
tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py:
##
@@ -73,6 +75,7 @@ def min_cluster_size(self):
jsancio commented on PR #13077:
URL: https://github.com/apache/kafka/pull/13077#issuecomment-1371398327
@cadonna can you review this PR?
Running system tests on this branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
jsancio opened a new pull request, #13077:
URL: https://github.com/apache/kafka/pull/13077
Add 3.3.x stream upgrade tests. The streams/upgrade-system-tests-33
directory was created by coping streams/upgrade-system-tests-32 without changes.
### Committer Checklist (excluded from
[
https://issues.apache.org/jira/browse/KAFKA-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephane Maarek updated KAFKA-14573:
Description:
Create a topic with 6 partitions (that's how the behavior is observed)
```
[
https://issues.apache.org/jira/browse/KAFKA-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephane Maarek updated KAFKA-14573:
Description:
Create a topic with 6 partitions (that's how the behavior is observed)
```
Stephane Maarek created KAFKA-14573:
---
Summary: RoundRobinPartitioner doesn't work as expected with topic
that has 6 partitions
Key: KAFKA-14573
URL: https://issues.apache.org/jira/browse/KAFKA-14573
jsancio commented on PR #13076:
URL: https://github.com/apache/kafka/pull/13076#issuecomment-1371367643
@cadonna can you review this PR?
Running system tests on this branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
jsancio opened a new pull request, #13076:
URL: https://github.com/apache/kafka/pull/13076
Now that 3.3.x exist, add system tests for upgrade, downgrade and client
compatibility.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [
jsancio commented on code in PR #12210:
URL: https://github.com/apache/kafka/pull/12210#discussion_r1061836000
##
tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py:
##
@@ -73,6 +75,7 @@ def min_cluster_size(self):
Matthias J. Sax created KAFKA-14572:
---
Summary: Migrate EmbeddedKafkaCluster used by Streams integration
tests from EmbeddedZookeeper to KRaft
Key: KAFKA-14572
URL:
mimaison commented on PR #13052:
URL: https://github.com/apache/kafka/pull/13052#issuecomment-1371348167
Yes but I can't merge it in the 3.4 branch at the moment as it's frozen for
the release. I'll try to remember to do it once 3.4.0 is out. Feel free to
follow up here if you don't see it
[
https://issues.apache.org/jira/browse/KAFKA-14279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14279:
---
Description:
Per the penultimate bullet on the [release
csolidum commented on PR #13052:
URL: https://github.com/apache/kafka/pull/13052#issuecomment-1371337791
@mimaison Thanks for merging. Would it be possible to get this included in
the 3.4.1 patch?
--
This is an automated message from the Apache Git Service.
To respond to the message,
ijuma commented on PR #13073:
URL: https://github.com/apache/kafka/pull/13073#issuecomment-1371218226
@edoardocomar Got it. If this is not exposed internally, then we can adjust
it back to minor.
--
This is an automated message from the Apache Git Service.
To respond to the message,
edoardocomar commented on PR #13073:
URL: https://github.com/apache/kafka/pull/13073#issuecomment-1371208107
> Thanks for the PR. Does this mean we are returning incorrect information
to clients?
Hi @ijuma
thankfully we're not returning incorrect info in the describeCluster API
chia7712 opened a new pull request, #13075:
URL: https://github.com/apache/kafka/pull/13075
```
[2019-06-11 17:58:46,304] ERROR [ReplicaAlterLogDirsThread-1]: Error due to
(kafka.server.ReplicaAlterLogDirsThread)
org.apache.kafka.common.KafkaException: Error processing data for
ruslankrivoshein opened a new pull request, #13074:
URL: https://github.com/apache/kafka/pull/13074
Since 0.10.1.2 is long ago released, this config param should be revealed.
This PR doesn't touch codebase, so no necessary to test it.
--
This is an automated message from the
ijuma commented on PR #13073:
URL: https://github.com/apache/kafka/pull/13073#issuecomment-1371169685
Thanks for the PR. Does this mean we are returning incorrect information to
clients?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14571:
Fix Version/s: 3.3.3
3.4.0
> ZkMetadataCache.getClusterMetadata is missing
[
https://issues.apache.org/jira/browse/KAFKA-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14571:
Priority: Major (was: Blocker)
> ZkMetadataCache.getClusterMetadata is missing rack information
[
https://issues.apache.org/jira/browse/KAFKA-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14571:
Priority: Blocker (was: Minor)
> ZkMetadataCache.getClusterMetadata is missing rack information
ijuma commented on PR #13043:
URL: https://github.com/apache/kafka/pull/13043#issuecomment-1371165209
@satishd Just checking that you saw the review for this PR (there was an
issue with the notifications in a previous one, I believe). I was planning to
merge this before reviewing the next
ivanyu commented on code in PR #13067:
URL: https://github.com/apache/kafka/pull/13067#discussion_r1061663838
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
ivanyu commented on PR #13067:
URL: https://github.com/apache/kafka/pull/13067#issuecomment-1371142944
@ijuma I don't see much difference with `QuorumControllerMetrics` on the low
level.
Tags are not used in `QuorumControllerMetrics` (this is situational I
think); type names are set
tombentley commented on code in PR #13071:
URL: https://github.com/apache/kafka/pull/13071#discussion_r1061629778
##
docs/security.html:
##
@@ -677,7 +677,11 @@ To configure SASL authentication on the clients, select
a SASL
mechanism that
is enabled
mimaison commented on code in PR #13071:
URL: https://github.com/apache/kafka/pull/13071#discussion_r1061610280
##
docs/security.html:
##
@@ -677,7 +677,11 @@ To configure SASL authentication on the clients, select
a SASL
mechanism that
is enabled in
ivanyu commented on code in PR #13065:
URL: https://github.com/apache/kafka/pull/13065#discussion_r1061598386
##
storage/src/main/java/org/apache/kafka/server/log/internals/LoadedLogOffsets.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
ivanyu commented on code in PR #13065:
URL: https://github.com/apache/kafka/pull/13065#discussion_r1061598967
##
storage/src/main/java/org/apache/kafka/server/log/internals/LoadedLogOffsets.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
ivanyu commented on code in PR #13065:
URL: https://github.com/apache/kafka/pull/13065#discussion_r1061595160
##
storage/src/main/java/org/apache/kafka/server/log/internals/LoadedLogOffsets.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Summary: Improving Interceptor Resource Leakage Prevention (was:
Interceptor Resource Leakage
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Summary: Interceptor Resource Leakage Prevention (was: Add A No
Implementation Default Open
edoardocomar commented on PR #13073:
URL: https://github.com/apache/kafka/pull/13073#issuecomment-1371027547
commit can be cherry picked cleanly in 3.3
--
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
edoardocomar opened a new pull request, #13073:
URL: https://github.com/apache/kafka/pull/13073
`ZkMetadataCache.getClusterMetadata` returns a Cluster object where the
aliveNodes were missing their rack info.
problem: when ZkMetadataCache updates the metadataSnapshot, includes the
[
https://issues.apache.org/jira/browse/KAFKA-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-14571:
--
Summary: ZkMetadataCache.getClusterMetadata is missing rack information in
aliveNodes (was:
Edoardo Comar created KAFKA-14571:
-
Summary: ZkMetadataCache.getClusterMetadata is missing rack
information for aliveNodes
Key: KAFKA-14571
URL: https://issues.apache.org/jira/browse/KAFKA-14571
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
iamazy updated KAFKA-14570:
---
Description: In
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
iamazy updated KAFKA-14570:
---
Summary: Problem description missing closing parenthesis symbol (was:
Problem description missing right
iamazy opened a new pull request, #13072:
URL: https://github.com/apache/kafka/pull/13072
There should add missing closing parenthesis symbol for problem description.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
iamazy updated KAFKA-14570:
---
Description: In
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
iamazy updated KAFKA-14570:
---
Description: In
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
iamazy updated KAFKA-14570:
---
Description: In
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
iamazy updated KAFKA-14570:
---
Description: In
[
https://issues.apache.org/jira/browse/KAFKA-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
iamazy updated KAFKA-14570:
---
Description: In
iamazy created KAFKA-14570:
--
Summary: Problem description missing right parenthesis symbol
Key: KAFKA-14570
URL: https://issues.apache.org/jira/browse/KAFKA-14570
Project: Kafka
Issue Type:
lbownik commented on code in PR #13067:
URL: https://github.com/apache/kafka/pull/13067#discussion_r1061467816
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
lbownik commented on code in PR #13067:
URL: https://github.com/apache/kafka/pull/13067#discussion_r1061466176
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
lbownik commented on code in PR #13067:
URL: https://github.com/apache/kafka/pull/13067#discussion_r1061458021
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14566:
Description:
h2. PROBLEM
The Consumer and Producer interceptor interfaces and their
[
https://issues.apache.org/jira/browse/KAFKA-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14566:
Description:
h2. PROBLEM
The Consumer and Producer interceptor interfaces and their
lbownik commented on code in PR #13067:
URL: https://github.com/apache/kafka/pull/13067#discussion_r1061455377
##
server-common/src/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
h2. PROBLEM
The Consumer and Producer interceptor interfaces and their
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
h2. PROBLEM
The Consumer and Producer interceptor interfaces and their
fvaleri commented on PR #13071:
URL: https://github.com/apache/kafka/pull/13071#issuecomment-1370887362
LGTM. This can spare some headaches.
--
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
vamossagar12 commented on code in PR #12802:
URL: https://github.com/apache/kafka/pull/12802#discussion_r1061433053
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -780,6 +774,14 @@ protected void stopServices() {
dengziming commented on code in PR #13050:
URL: https://github.com/apache/kafka/pull/13050#discussion_r1061409335
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -432,8 +432,8 @@ private Throwable handleEventException(String name,
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654417#comment-17654417
]
Ismael Juma commented on KAFKA-14524:
-
"I'm also wondering if the move away from Scala would qualify
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654415#comment-17654415
]
Ismael Juma edited comment on KAFKA-14524 at 1/4/23 11:47 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654413#comment-17654413
]
Matthew de Detrich edited comment on KAFKA-14524 at 1/4/23 11:45 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654415#comment-17654415
]
Ismael Juma commented on KAFKA-14524:
-
[~mdedetrich-aiven] Please check KAFKA-14470 where this is
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654413#comment-17654413
]
Matthew de Detrich edited comment on KAFKA-14524 at 1/4/23 11:44 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654413#comment-17654413
]
Matthew de Detrich commented on KAFKA-14524:
I believe the main intention of this is to
[
https://issues.apache.org/jira/browse/KAFKA-14545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14545:
---
Affects Version/s: 3.4.0
> MirrorCheckpointTask throws NullPointerException when group
1 - 100 of 120 matches
Mail list logo
