tombentley commented on a change in pull request #9878:
URL: https://github.com/apache/kafka/pull/9878#discussion_r662782741
##
File path:
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java
##
@@ -27,217 +28,107 @@
/**
* A flexible future which s
Frode Carlsen created KAFKA-13027:
-
Summary: Support for Jakarta EE 9.x to allow applications to
migrate
Key: KAFKA-13027
URL: https://issues.apache.org/jira/browse/KAFKA-13027
Project: Kafka
dengziming commented on pull request #10958:
URL: https://github.com/apache/kafka/pull/10958#issuecomment-872727981
@mjsax @lct45 , 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 spec
dengziming opened a new pull request #10958:
URL: https://github.com/apache/kafka/pull/10958
*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.*
We change defaul
dengziming opened a new pull request #10957:
URL: https://github.com/apache/kafka/pull/10957
*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.*
We can remove `D
dengziming commented on pull request #10957:
URL: https://github.com/apache/kafka/pull/10957#issuecomment-872693132
@jolshan Should we delete this?
--
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 t
dengziming commented on pull request #10956:
URL: https://github.com/apache/kafka/pull/10956#issuecomment-872689440
ping @cmccabe , I'm also thinking about moving `MetadataCache` into
`kafka.server.metadata` , WDYT?
--
This is an automated message from the Apache Git Service.
To respond
dengziming opened a new pull request #10956:
URL: https://github.com/apache/kafka/pull/10956
*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 package name
jeffkbkim edited a comment on pull request #10955:
URL: https://github.com/apache/kafka/pull/10955#issuecomment-872667997
--
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
jeffkbkim edited a comment on pull request #10955:
URL: https://github.com/apache/kafka/pull/10955#issuecomment-872667997
ran benchmark with warm up = 5, iteration = 5
With changes:
```
Benchmark (partitionCount)
(topicCount) Mode
jeffkbkim edited a comment on pull request #10955:
URL: https://github.com/apache/kafka/pull/10955#issuecomment-872667997
ran benchmark with warm up = 5, iteration = 5
With changes:
```
Benchmark (partitionCount)
(topicCount) Mode
jeffkbkim edited a comment on pull request #10955:
URL: https://github.com/apache/kafka/pull/10955#issuecomment-872667997
ran benchmark with warm up = 5, iteration = 5
With changes:
```
Benchmark (partitionCount)
(topicCount) Mode
jeffkbkim commented on pull request #10955:
URL: https://github.com/apache/kafka/pull/10955#issuecomment-872667997
ran benchmark with warm up = 5, iteration = 5
With changes:
```
Benchmark (partitionCount)
(topicCount) Mode Cnt
jeffkbkim opened a new pull request #10955:
URL: https://github.com/apache/kafka/pull/10955
new benchmark to test KafkaAdminClient.getListOffsetsCalls
originated from https://github.com/apache/kafka/pull/10940
### Committer Checklist (excluded from commit message)
- [ ] Verify d
[
https://issues.apache.org/jira/browse/KAFKA-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-12717.
---
Reviewer: Randall Hauch
Resolution: Fixed
Merged to the `trunk` branch for 3.0.0.
> R
rhauch merged pull request #10854:
URL: https://github.com/apache/kafka/pull/10854
--
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..
rhauch commented on pull request #10854:
URL: https://github.com/apache/kafka/pull/10854#issuecomment-872657319
Only one Connect-related failure across all the tests, and it's an
integration test that is known to be flaky.
--
This is an automated message from the Apache Git Service.
To r
gwenshap closed pull request #10937:
URL: https://github.com/apache/kafka/pull/10937
--
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
xvrl commented on a change in pull request #10937:
URL: https://github.com/apache/kafka/pull/10937#discussion_r662679257
##
File path: core/src/main/scala/kafka/tools/MirrorMaker.scala
##
@@ -455,7 +455,13 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
.d
xvrl commented on a change in pull request #10937:
URL: https://github.com/apache/kafka/pull/10937#discussion_r662677742
##
File path: core/src/main/scala/kafka/tools/MirrorMaker.scala
##
@@ -455,7 +455,13 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
.d
xvrl commented on a change in pull request #10937:
URL: https://github.com/apache/kafka/pull/10937#discussion_r662677742
##
File path: core/src/main/scala/kafka/tools/MirrorMaker.scala
##
@@ -455,7 +455,13 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
.d
xvrl commented on pull request #9439:
URL: https://github.com/apache/kafka/pull/9439#issuecomment-872646404
closing in favor of #10937
--
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 specif
xvrl closed pull request #9439:
URL: https://github.com/apache/kafka/pull/9439
--
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...@ka
skaundinya15 opened a new pull request #10954:
URL: https://github.com/apache/kafka/pull/10954
This implements KIP-709:
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=173084258
It updates the `OffsetFetch` request and response to support fetching
offsets for multip
[
https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-12879:
-
Assignee: Kirk True
> Compatibility break in Admin.listOffsets()
>
[
https://issues.apache.org/jira/browse/KAFKA-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373115#comment-17373115
]
Konstantine Karantasis commented on KAFKA-6987:
---
Added a review on the 11th
kkonstantine commented on a change in pull request #9878:
URL: https://github.com/apache/kafka/pull/9878#discussion_r662652853
##
File path:
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java
##
@@ -27,217 +28,107 @@
/**
* A flexible future which
guozhangwang commented on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-872620746
Many thanks to @cadonna ! Need you to review now :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
guozhangwang opened a new pull request #10953:
URL: https://github.com/apache/kafka/pull/10953
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
cmccabe merged pull request #10946:
URL: https://github.com/apache/kafka/pull/10946
--
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.
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662643922
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- over
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662643681
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1048,9 +1058,14 @@ object KafkaConfig {
.defineInternal(InitialBrokerRegist
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662643427
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2089,7 +2090,7 @@ private long pollUnattachedAsObserver(UnattachedState
[
https://issues.apache.org/jira/browse/KAFKA-13020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-13020:
---
Description:
We want to expose control messages through {{o.a.k.r.Ba
hachikuji commented on a change in pull request #10931:
URL: https://github.com/apache/kafka/pull/10931#discussion_r661670006
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -264,19 +266,13 @@ class BrokerServer(
/* Add all reconfigurables for con
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662635099
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2153,14 +2154,36 @@ private boolean maybeCompleteShutdown(long
current
[
https://issues.apache.org/jira/browse/KAFKA-12974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio resolved KAFKA-12974.
Resolution: Fixed
Already fixed. Default set to 20MB.
> Change th
mjsax merged pull request #10917:
URL: https://github.com/apache/kafka/pull/10917
--
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...
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662623797
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- overr
rhauch edited a comment on pull request #10854:
URL: https://github.com/apache/kafka/pull/10854#issuecomment-872586150
@C0urante, thanks for fixing the minor conflict!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
rhauch commented on pull request #10854:
URL: https://github.com/apache/kafka/pull/10854#issuecomment-872586150
@C0urante, can you please fix the minor conflict? Looks like a trivial fix,
but I'm unable to push to your PR branch. Thanks!
--
This is an automated message from the Apache Gi
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662623797
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- overr
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662622540
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1048,9 +1058,14 @@ object KafkaConfig {
.defineInternal(InitialBrokerRegistr
jolshan commented on a change in pull request #10892:
URL: https://github.com/apache/kafka/pull/10892#discussion_r662621155
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -209,65 +209,59 @@ default CreateTopicsResult
createTopics(Collection
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662620593
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2651,7 +2651,7 @@ object Log extends Logging {
* @tparam T the type of object held within
ijuma commented on a change in pull request #10892:
URL: https://github.com/apache/kafka/pull/10892#discussion_r662620347
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -209,65 +209,59 @@ default CreateTopicsResult
createTopics(Collection n
[
https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-8613.
Resolution: Fixed
> Make grace period mandatory
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13020:
-
Summary: SnapshotReader should decode and report the append time in the
header (was: SnapshotRe
[
https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9559:
---
Description:
The current default "default serde" is not particularly useful, and in almost
a
[
https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9559:
---
Labels: kip (was: needs-kip)
> Change the default "default serde" from ByteArraySerde to nul
mjsax merged pull request #10813:
URL: https://github.com/apache/kafka/pull/10813
--
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...
cmccabe commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662614408
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -495,6 +506,10 @@ public int sizeInBytes() {
public
jsancio commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662610242
##
File path: metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java
##
@@ -198,7 +207,12 @@ synchronized void unregisterLogManager(LocalLog
jsancio commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662608352
##
File path: raft/src/main/java/org/apache/kafka/raft/Batch.java
##
@@ -99,38 +116,68 @@ public boolean equals(Object o) {
Batch batch = (Batch)
jsancio commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662608275
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -207,6 +208,12 @@ private void completeCurrentBatch() {
jsancio commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662604574
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedCounter.java
##
@@ -106,7 +108,10 @@ public synchronized void handleCommit(BatchReader
r
cmccabe commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662602197
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -207,6 +208,12 @@ private void completeCurrentBatch() {
cmccabe commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662601954
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedCounter.java
##
@@ -106,7 +108,10 @@ public synchronized void handleCommit(BatchReader
r
[
https://issues.apache.org/jira/browse/KAFKA-12964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12964.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk
> Corrupt segment recovery can del
cmccabe commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662600721
##
File path: raft/src/main/java/org/apache/kafka/raft/Batch.java
##
@@ -99,38 +116,68 @@ public boolean equals(Object o) {
Batch batch = (Batch)
junrao merged pull request #10896:
URL: https://github.com/apache/kafka/pull/10896
--
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..
cmccabe commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662599796
##
File path: metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java
##
@@ -198,7 +207,12 @@ synchronized void unregisterLogManager(LocalLog
[
https://issues.apache.org/jira/browse/KAFKA-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-13025:
---
Labels: kip-500 (was: )
> Add more information to the Snapshot head
hachikuji merged pull request #10940:
URL: https://github.com/apache/kafka/pull/10940
--
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-unsubsc
jsancio commented on a change in pull request #10946:
URL: https://github.com/apache/kafka/pull/10946#discussion_r662594464
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -495,6 +506,10 @@ public int sizeInBytes() {
public
Cheng Tan created KAFKA-13026:
-
Summary: Idempotent producer (KAFKA-10619) follow-up
Key: KAFKA-13026
URL: https://issues.apache.org/jira/browse/KAFKA-13026
Project: Kafka
Issue Type: Improvemen
mimaison merged pull request #10743:
URL: https://github.com/apache/kafka/pull/10743
--
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
jsancio commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662550101
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1048,9 +1058,14 @@ object KafkaConfig {
.defineInternal(InitialBrokerRegist
garyrussell commented on pull request #7670:
URL: https://github.com/apache/kafka/pull/7670#issuecomment-872514693
Can we PLEASE get this merged? It is incredibly difficult to track down
problems in code that calls the clients, if we can't tell where the call is
made from.
--
This is an
Niket Goel created KAFKA-13025:
--
Summary: Add more information to the Snapshot header and footer
Key: KAFKA-13025
URL: https://issues.apache.org/jira/browse/KAFKA-13025
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-12952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niket Goel updated KAFKA-12952:
---
Description:
Create new Control Records that will serve as the header and footer for a
Metadata Sna
jolshan opened a new pull request #10952:
URL: https://github.com/apache/kafka/pull/10952
Store topic ID info in consumer metadata. We will always take the topic ID
from the latest metadata response and remove any topic IDs from the cache if
the metadata response did not return a topic ID
[
https://issues.apache.org/jira/browse/KAFKA-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373002#comment-17373002
]
Kirk True commented on KAFKA-12841:
---
I have submitted a [pull request|https://github.c
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662522112
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- over
[
https://issues.apache.org/jira/browse/KAFKA-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-12841:
-
Assignee: Kirk True
> NPE from the provided metadata in client callback in case of ApiException
kirktrue commented on pull request #10951:
URL: https://github.com/apache/kafka/pull/10951#issuecomment-872470098
@ayoukhananov - you're absolutely correct that there are conditions wherein
`tp` wasn't initialized. This should fix that case too.
--
This is an automated message from the A
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662517391
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -16,34 +16,41 @@
*/
package kafka.raft
-import java.io.File
-import java.nio
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662517293
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -16,34 +16,41 @@
*/
package kafka.raft
-import java.io.File
-import java.nio
jeffkbkim commented on pull request #10940:
URL: https://github.com/apache/kafka/pull/10940#issuecomment-872467503
@showuon thanks!
on the time complexity, i think you may have missed the for-loop wrapped
around.
--
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/KAFKA-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372989#comment-17372989
]
Avi Youkhananov edited comment on KAFKA-12841 at 7/1/21, 6:31 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372989#comment-17372989
]
Avi Youkhananov commented on KAFKA-12841:
-
[~kirktrue] This is what i did in thi
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662509722
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2153,14 +2154,36 @@ private boolean maybeCompleteShutdown(long
current
jeffkbkim commented on pull request #10940:
URL: https://github.com/apache/kafka/pull/10940#issuecomment-872460573
i have renamed cluster() to buildCluster(). i will submit a separate PR for
the benchmark
--
This is an automated message from the Apache Git Service.
To respond to the mess
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662506190
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- overr
mumrah commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662505337
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- overr
[
https://issues.apache.org/jira/browse/KAFKA-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372984#comment-17372984
]
Kirk True commented on KAFKA-12841:
---
There are some conditions inside the {{KafkaProdu
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662498528
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- over
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662494186
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +313,152 @@ final class KafkaMetadataLog private (
}
}
- over
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662493849
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -312,26 +315,142 @@ final class KafkaMetadataLog private (
}
}
- over
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372977#comment-17372977
]
Bruno Cadonna edited comment on KAFKA-13010 at 7/1/21, 6:01 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372977#comment-17372977
]
Bruno Cadonna commented on KAFKA-13010:
---
Some logs that might be interesting:
{co
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662470041
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -16,34 +16,41 @@
*/
package kafka.raft
-import java.io.File
-import java.ni
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662470041
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -16,34 +16,41 @@
*/
package kafka.raft
-import java.io.File
-import java.ni
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662470041
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -16,34 +16,41 @@
*/
package kafka.raft
-import java.io.File
-import java.ni
cmccabe commented on a change in pull request #10864:
URL: https://github.com/apache/kafka/pull/10864#discussion_r662469119
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -16,34 +16,41 @@
*/
package kafka.raft
-import java.io.File
-import java.ni
OmniaGM commented on a change in pull request #10937:
URL: https://github.com/apache/kafka/pull/10937#discussion_r662449984
##
File path: core/src/main/scala/kafka/tools/MirrorMaker.scala
##
@@ -454,8 +454,8 @@ object MirrorMaker extends Logging with KafkaMetricsGroup {
[
https://issues.apache.org/jira/browse/KAFKA-12467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12467.
--
Fix Version/s: 3.0.0
Resolution: Fixed
> Implement QuorumController metadata snapshots
vamossagar12 commented on pull request #10798:
URL: https://github.com/apache/kafka/pull/10798#issuecomment-872399579
> You were referring to this commit
[68a947c](https://github.com/apache/kafka/commit/68a947c0eb6a5cc4bdde24083c83f4638e708edb)
as for the tweaks right?
>
> BTW it's
vamossagar12 commented on pull request #10798:
URL: https://github.com/apache/kafka/pull/10798#issuecomment-872398600
@guozhangwang , thats the commit i was referring to. Setting a byte order
and seems to have an impact on performance. Also, earlier i was calling put
first and then calling
[
https://issues.apache.org/jira/browse/KAFKA-13024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damien Gasparina updated KAFKA-13024:
-
Description:
{{KStream.repartition}} is silently filtering messages with null keys. A si
1 - 100 of 153 matches
Mail list logo
