chia7712 merged pull request #9989:
URL: https://github.com/apache/kafka/pull/9989
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 t
chia7712 commented on a change in pull request #10017:
URL: https://github.com/apache/kafka/pull/10017#discussion_r568403080
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -1948,7 +1948,7 @@ public OffsetAndMetadata committed(Top
chia7712 commented on a change in pull request #10017:
URL: https://github.com/apache/kafka/pull/10017#discussion_r568411777
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -1948,7 +1948,7 @@ public OffsetAndMetadata committed(Top
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-12257:
--
Attachment: KAFKA-12257.patch
> Consumer mishandles topics deleted and recreated with the same name
>
mjsax commented on a change in pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#discussion_r568413963
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Branched.scala
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache S
chia7712 closed pull request #9502:
URL: https://github.com/apache/kafka/pull/9502
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 t
mjsax commented on a change in pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#discussion_r568413267
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Branched.scala
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache S
chia7712 commented on a change in pull request #10012:
URL: https://github.com/apache/kafka/pull/10012#discussion_r568422389
##
File path:
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandler.java
#
dajac commented on a change in pull request #10007:
URL: https://github.com/apache/kafka/pull/10007#discussion_r568370315
##
File path:
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java
##
@@ -1777,6 +1785,74 @@ public void
testIn
[
https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276987#comment-17276987
]
Marco Lotz commented on KAFKA-9527:
---
[~mjsax] what would be the expected behaviour in t
[
https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-12261:
-
Description:
As of now, auto.offset.reset of ConsumerConfig is "latest" by default.
This cou
CaoManhDat commented on a change in pull request #10021:
URL: https://github.com/apache/kafka/pull/10021#discussion_r568473592
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -173,13 +164,16 @@ final class KafkaMetadataLog private (
override def t
dajac commented on pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#issuecomment-771527775
@bob-barrett Thanks for the PR. For my understanding, have we considered
changing the way backoff is applied instead of re-resolving when an established
connection is closed. For in
CaoManhDat commented on a change in pull request #10021:
URL: https://github.com/apache/kafka/pull/10021#discussion_r568482293
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -267,23 +261,31 @@ final class KafkaMetadataLog private (
}
}
- ov
rajinisivaram commented on a change in pull request #10007:
URL: https://github.com/apache/kafka/pull/10007#discussion_r568485297
##
File path:
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java
##
@@ -129,6 +136,22 @@ private static ChannelBuilder crea
rajinisivaram commented on a change in pull request #10007:
URL: https://github.com/apache/kafka/pull/10007#discussion_r568488231
##
File path:
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java
##
@@ -129,6 +136,22 @@ private static ChannelBuilder crea
rajinisivaram commented on pull request #10007:
URL: https://github.com/apache/kafka/pull/10007#issuecomment-771534377
@dajac Thanks for the review. Addressed comments and left a couple of
responses.
This is an automated mes
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-771541128
@dengziming Thanks for looking into this. Looks like a timing issue.
@jolshan had run two system test runs on this PR last week and both had these
consumer issues. At the ti
dajac commented on a change in pull request #10007:
URL: https://github.com/apache/kafka/pull/10007#discussion_r568499289
##
File path:
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java
##
@@ -129,6 +136,22 @@ private static ChannelBuilder create(Secur
dajac commented on a change in pull request #10007:
URL: https://github.com/apache/kafka/pull/10007#discussion_r568499761
##
File path:
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java
##
@@ -129,6 +136,22 @@ private static ChannelBuilder create(Secur
cadonna commented on a change in pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#discussion_r568508079
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java
##
@@ -434,6 +435,22 @@ public void
shouldRemov
cadonna commented on pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#issuecomment-771551918
@guozhangwang @vamossagar12 This failure is related to this PR:
```
org.apache.kafka.streams.state.internals.MeteredKeyValueStoreTest.shouldGetRecordsWithPrefixKey[0.10.0
xiao-penglei commented on pull request #9992:
URL: https://github.com/apache/kafka/pull/9992#issuecomment-771552356
> Looks like one of the tests got hung up and the build timed out:
>
> ```
> 16:04:09 SocketServerTest >
testStagedListenerShutdownWhenConnectionQueueIsFull() START
cadonna commented on pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#issuecomment-771553074
@vamossagar12 Probably, it would also be good to rebase this PR to current
trunk to get a green build since we merged a couple of fixes to flaky tests
recently.
cadonna commented on pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#issuecomment-771558421
> @cadonna could you also help @vamossagar12 to come up with a PR on docs
for this KIP?
Yes, @vamossagar12, you should open a PR and add a short paragraph about
KIP-614 in
xiao-penglei commented on pull request #9992:
URL: https://github.com/apache/kafka/pull/9992#issuecomment-771609535
> Looks like one of the tests got hung up and the build timed out:
>
> ```
> 16:04:09 SocketServerTest >
testStagedListenerShutdownWhenConnectionQueueIsFull() START
Rajini Sivaram created KAFKA-12268:
--
Summary: System tests broken because consumer returns early
without records
Key: KAFKA-12268
URL: https://issues.apache.org/jira/browse/KAFKA-12268
Project: Kafk
dengziming created KAFKA-12269:
--
Summary: Replace MetadataResponse.PartitionMetadata with
auto-generated protocol
Key: KAFKA-12269
URL: https://issues.apache.org/jira/browse/KAFKA-12269
Project: Kafka
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-771612611
Looks like a bug was introduced by a different PR, opened
https://issues.apache.org/jira/browse/KAFKA-12268 to fix this.
---
[
https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-9881:
Assignee: Bruno Cadonna
> Verify whether RocksDBMetrics Get Measurements from RocksDB in a
[
https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna closed KAFKA-9881.
> Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test
> instead of an Intergrat
[
https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-9881.
--
Resolution: Fixed
> Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test
[
https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-9881:
-
Fix Version/s: 2.6.0
> Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test
C0urante commented on a change in pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#discussion_r568599861
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -171,13 +171,9 @@ protected void close() {
C0urante commented on a change in pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#discussion_r568603419
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -202,6 +198,8 @@ public void removeMetrics() {
C0urante commented on a change in pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#discussion_r568612017
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectWorkerIntegrationTest.java
##
@@ -288,14 +289,42 @@ public void
rajinisivaram opened a new pull request #10022:
URL: https://github.com/apache/kafka/pull/10022
Changes from https://issues.apache.org/jira/browse/KAFKA-10866 cause early
return from KafkaConsumer.poll() even when records are not available. We should
respect timeout specified in poll() and
[
https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leah Thomas resolved KAFKA-10366.
-
Fix Version/s: 2.8.0
Resolution: Fixed
> TimeWindowedDeserializer doesn't allow users to
[
https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leah Thomas resolved KAFKA-9649.
Fix Version/s: 2.8.0
Resolution: Fixed
> Remove/Warn on use of TimeWindowedSerde with no spe
ijuma commented on a change in pull request #9836:
URL: https://github.com/apache/kafka/pull/9836#discussion_r568623108
##
File path: build.gradle
##
@@ -1070,6 +1070,7 @@ project(':clients') {
testCompile libs.junitJupiterApi
testCompile libs.junitVintageEngine
ijuma commented on pull request #9836:
URL: https://github.com/apache/kafka/pull/9836#issuecomment-771655746
Have we verified that this doesn't cause perf regressions? It seems to have
caused system test failures: https://issues.apache.org/jira/browse/KAFKA-12268
-
C0urante commented on pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#issuecomment-771673592
Thanks for taking a look @gharris1727. I've tried to address your comments;
let me know what you think.
This i
ijuma commented on a change in pull request #10009:
URL: https://github.com/apache/kafka/pull/10009#discussion_r568649417
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala
##
@@ -615,7 +615,7 @@ class TransactionCoordinator(brokerId:
ijuma commented on a change in pull request #10009:
URL: https://github.com/apache/kafka/pull/10009#discussion_r568650224
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala
##
@@ -615,7 +615,7 @@ class TransactionCoordinator(brokerId:
ijuma commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r568653073
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -316,7 +324,7 @@ class ReplicaManager(val config: KafkaConfig,
private def mayb
C0urante commented on a change in pull request #10014:
URL: https://github.com/apache/kafka/pull/10014#discussion_r568653512
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -381,7 +381,7 @@ public void tick(
C0urante commented on a change in pull request #10014:
URL: https://github.com/apache/kafka/pull/10014#discussion_r568654782
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java
##
@@ -2161,6 +2163,83 @@ public Boo
C0urante commented on pull request #10014:
URL: https://github.com/apache/kafka/pull/10014#issuecomment-771682136
Thanks @gharris1727; I've tried to address your comments. Let me know what
you think.
This is an automated mes
dengziming commented on a change in pull request #10021:
URL: https://github.com/apache/kafka/pull/10021#discussion_r568656400
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -173,13 +164,16 @@ final class KafkaMetadataLog private (
override def t
dengziming commented on a change in pull request #10021:
URL: https://github.com/apache/kafka/pull/10021#discussion_r568656553
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -267,23 +261,31 @@ final class KafkaMetadataLog private (
}
}
- ov
CaoManhDat commented on a change in pull request #10021:
URL: https://github.com/apache/kafka/pull/10021#discussion_r568657609
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -173,13 +164,16 @@ final class KafkaMetadataLog private (
override def t
rajinisivaram commented on pull request #10007:
URL: https://github.com/apache/kafka/pull/10007#issuecomment-771691510
@dajac Thanks for the review. Test failures not related, merging to trunk.
This is an automated message fr
rajinisivaram merged pull request #10007:
URL: https://github.com/apache/kafka/pull/10007
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-10700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-10700.
Reviewer: David Jacot
Resolution: Fixed
> Support mutual TLS authentication for SASL
ijuma commented on a change in pull request #10019:
URL: https://github.com/apache/kafka/pull/10019#discussion_r568672128
##
File path: core/src/main/scala/kafka/server/KafkaBroker.scala
##
@@ -0,0 +1,113 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or
inponomarev commented on a change in pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#discussion_r568681712
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Branched.scala
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/KAFKA-12263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley reassigned KAFKA-12263:
---
Assignee: Tom Bentley
> Improve MockClient RequestMatcher interface
> -
rondagostino commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r568716273
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -316,7 +324,7 @@ class ReplicaManager(val config: KafkaConfig,
private d
mumrah commented on a change in pull request #10018:
URL: https://github.com/apache/kafka/pull/10018#discussion_r568720185
##
File path: core/src/main/scala/kafka/server/metadata/MetadataBrokers.scala
##
@@ -0,0 +1,143 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF
mumrah commented on a change in pull request #10018:
URL: https://github.com/apache/kafka/pull/10018#discussion_r568723408
##
File path: core/src/main/scala/kafka/server/metadata/MetadataBrokers.scala
##
@@ -0,0 +1,143 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF
rondagostino commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r568730408
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -257,6 +264,37 @@ class ReplicaManager(val config: KafkaConfig,
}
}
mumrah commented on a change in pull request #10018:
URL: https://github.com/apache/kafka/pull/10018#discussion_r568731023
##
File path: core/src/main/scala/kafka/server/metadata/MetadataPartitions.scala
##
@@ -0,0 +1,282 @@
+/**
+ * Licensed to the Apache Software Foundation (
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277249#comment-17277249
]
John Roesler commented on KAFKA-10091:
--
Reopened, since I still need to update the
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-10091:
--
> Improve task idling
> ---
>
> Key: KAFKA-10091
>
Randall Hauch created KAFKA-12270:
-
Summary: Kafka Connect may fail a task when racing to create topic
Key: KAFKA-12270
URL: https://issues.apache.org/jira/browse/KAFKA-12270
Project: Kafka
I
rondagostino commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r568756317
##
File path: core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala
##
@@ -111,7 +111,7 @@ class ReplicaAlterLogDirsThread(name: String,
chia7712 commented on pull request #10022:
URL: https://github.com/apache/kafka/pull/10022#issuecomment-771781849
How about making ```Fetcher#fetchedRecords``` update metadata only if
records is not empty? In other words, the
[Fetcher.java#L643](https://github.com/apache/kafka/blob/trunk/c
rajinisivaram commented on pull request #10022:
URL: https://github.com/apache/kafka/pull/10022#issuecomment-771813678
@chia7712 Thanks for the review. There is a test that verifies that we get
metadata even when there are no records
(https://github.com/apache/kafka/blob/5c562efb2d76407011
tombentley opened a new pull request #10023:
URL: https://github.com/apache/kafka/pull/10023
As described in
[KAFKA-12263](https://issues.apache.org/jira/browse/KAFKA-12263), this PR
refactors `MockClient.RequestMatcher` to become `MockClient.RequestAssertion`
using assertions in the impl
tombentley commented on pull request #10023:
URL: https://github.com/apache/kafka/pull/10023#issuecomment-771821577
@hachikuji since you raised the JIRA perhaps you could review this to check
it's what you were after?
This i
[
https://issues.apache.org/jira/browse/KAFKA-12263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-12263:
Flags: Patch
Labels: patch-available (was: )
> Improve MockClient RequestMatcher interface
>
bob-barrett commented on pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#issuecomment-771823264
> For instance, we could try all the resolved IPs before applying the
backoff. However, we would still have to wait until the connection timeouts for
each IP.
@dajac Th
David Arthur created KAFKA-12271:
Summary: Expose consistent Raft metadata to components
Key: KAFKA-12271
URL: https://issues.apache.org/jira/browse/KAFKA-12271
Project: Kafka
Issue Type: Imp
aloknnikhil commented on a change in pull request #9996:
URL: https://github.com/apache/kafka/pull/9996#discussion_r568814206
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java
##
@@ -123,6 +124,9 @@
/** indicates whether the API is enabled f
mjsax merged pull request #10020:
URL: https://github.com/apache/kafka/pull/10020
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 th
mjsax commented on pull request #9568:
URL: https://github.com/apache/kafka/pull/9568#issuecomment-771851220
Back ported to `2.6` via #10020
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/KAFKA-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10689:
Fix Version/s: 2.6.2
> Assignor can't determine number of partitions on FJK with upstream
Damien Gasparina created KAFKA-12272:
Summary: Kafka Streams metric commit-latency-max and
commit-latency-avg is always 0
Key: KAFKA-12272
URL: https://issues.apache.org/jira/browse/KAFKA-12272
Pr
mjsax merged pull request #9974:
URL: https://github.com/apache/kafka/pull/9974
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
mjsax commented on pull request #9974:
URL: https://github.com/apache/kafka/pull/9974#issuecomment-771856604
Thanks for the PR @lct45!
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/KAFKA-12272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-12272:
---
Assignee: Matthias J. Sax
> Kafka Streams metric commit-latency-max and commit-late
[
https://issues.apache.org/jira/browse/KAFKA-12272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12272:
Fix Version/s: 2.6.2
2.7.1
2.8.0
> Kafka Streams met
gharris1727 commented on a change in pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#discussion_r568823888
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -171,13 +171,9 @@ protected void close() {
gharris1727 commented on a change in pull request #10014:
URL: https://github.com/apache/kafka/pull/10014#discussion_r568830939
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -381,7 +381,7 @@ public void ti
abbccdda commented on a change in pull request #10017:
URL: https://github.com/apache/kafka/pull/10017#discussion_r568845018
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -1948,7 +1948,7 @@ public OffsetAndMetadata committed(Top
Chia-Ping Tsai created KAFKA-12273:
--
Summary: InterBrokerSendThread#pollOnce throws FatalExitError even
though it is shutdown correctly
Key: KAFKA-12273
URL: https://issues.apache.org/jira/browse/KAFKA-12273
chia7712 opened a new pull request #10024:
URL: https://github.com/apache/kafka/pull/10024
issue: https://issues.apache.org/jira/browse/KAFKA-12273
kafka tests sometimes shutdown gradle process with non-zero code. The (one
of) root cause is that ```InterBrokerSendThread#pollOnce``` e
ijuma commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r568860838
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -316,7 +324,7 @@ class ReplicaManager(val config: KafkaConfig,
private def mayb
ijuma commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r568862000
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -891,7 +944,7 @@ class ReplicaManager(val config: KafkaConfig,
def processFai
cmccabe merged pull request #9901:
URL: https://github.com/apache/kafka/pull/9901
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 th
inponomarev commented on pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#issuecomment-771925298
Hi @mjsax , I have rebased and manually merged conflicts, and also removed
`FunctionConverters`
JDK8 build still fails, but this time much later -- something related to
[
https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman closed KAFKA-12190.
--
> Failure on Windows due to an UnsupportedOperationException when
> StateDirector
[
https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman closed KAFKA-9176.
-
> Flaky test failure:
> OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyS
[
https://issues.apache.org/jira/browse/KAFKA-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman closed KAFKA-10867.
--
> Implement improved semantics using the ConsumerRecords meta
> --
C0urante commented on pull request #10014:
URL: https://github.com/apache/kafka/pull/10014#issuecomment-771935468
Ah whoops, the `PowerMock::verifyAll` broke the unit tests. Patched them up;
should be good to go now.
This is
kkonstantine merged pull request #9319:
URL: https://github.com/apache/kafka/pull/9319
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
Michał Łukowicz created KAFKA-12274:
---
Summary: Transactional operation fails when broker is replaced
using the same broker ID.
Key: KAFKA-12274
URL: https://issues.apache.org/jira/browse/KAFKA-12274
ableegoldman commented on pull request #9247:
URL: https://github.com/apache/kafka/pull/9247#issuecomment-771942436
Cherrypicked to 2.6 for 2.6.2 release
This is an automated message from the Apache Git Service.
To respond 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 w
[
https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10362:
---
Fix Version/s: 2.6.2
> When resuming Streams active task with EOS, the check
1 - 100 of 273 matches
Mail list logo
