thake commented on pull request #9338:
URL: https://github.com/apache/kafka/pull/9338#issuecomment-699857289
The remaining failing tests do not seem to be related to this PR.
This is an automated message from the Apache Git S
huangyiminghappy commented on pull request #9304:
URL: https://github.com/apache/kafka/pull/9304#issuecomment-699862527
> Reading on the SO thread I think this fix makes sense. Merging to trunk
now.
thanks
This is an
manijndl7 commented on a change in pull request #9255:
URL: https://github.com/apache/kafka/pull/9255#discussion_r495786493
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -1271,4 +1274,34 @@ private static byte checkRange(final byte i) {
edenhill commented on a change in pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#discussion_r495804848
##
File path: tests/docker/Dockerfile
##
@@ -32,9 +32,11 @@ ARG ducker_creator=default
LABEL ducker.creator=$ducker_creator
# Update Linux and install
chia7712 commented on pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#issuecomment-699902060
rebase to fix conflicts
This is an automated message from the Apache Git Service.
To respond to the message, plea
mimaison commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r495817863
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java
##
@@ -119,4 +120,41 @@ public void testNonMutat
nizhikov commented on a change in pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#discussion_r495820772
##
File path: tests/docker/Dockerfile
##
@@ -32,9 +32,11 @@ ARG ducker_creator=default
LABEL ducker.creator=$ducker_creator
# Update Linux and install
edenhill commented on a change in pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#discussion_r495836397
##
File path: tests/docker/Dockerfile
##
@@ -32,9 +32,11 @@ ARG ducker_creator=default
LABEL ducker.creator=$ducker_creator
# Update Linux and install
Oliver Weiler created KAFKA-10530:
-
Summary: kafka-streams-application-reset misses some internal
topics
Key: KAFKA-10530
URL: https://issues.apache.org/jira/browse/KAFKA-10530
Project: Kafka
mimaison opened a new pull request #9343:
URL: https://github.com/apache/kafka/pull/9343
Trigger task reconfiguration when:
- topic-partitions are created or deleted on source cluster
- topic-partitions are missing on target cluster
Co-authored-by: Mickael Maison
Co-authored
mimaison commented on pull request #9343:
URL: https://github.com/apache/kafka/pull/9343#issuecomment-699932205
cc @ryannedolan
This is an automated message from the Apache Git Service.
To respond to the message, please log
dajac opened a new pull request #9344:
URL: https://github.com/apache/kafka/pull/9344
KIP-599 had proposed to keep returning the
`ThrottlingQuotaExceededException` to the called even when the request times
out due to reaching `default.api.timeout.ms`. The current implementation does
not c
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r495871017
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
dajac commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r495882544
##
File path: core/src/main/resources/common/message/GroupMetadataResponse.json
##
@@ -0,0 +1,103 @@
+// Licensed to the Apache Software Foundation (ASF) unde
[
https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203203#comment-17203203
]
Igor commented on KAFKA-9747:
-
Same issue for Debezium (SqlServer connector)
> No tasks crea
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r495918349
##
File path: core/src/main/resources/common/message/GroupMetadataRequest.json
##
@@ -0,0 +1,27 @@
+// Licensed to the Apache Software Foundation (ASF) und
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r495919910
##
File path: core/src/main/resources/common/message/OffsetCommitResponse.json
##
@@ -0,0 +1,52 @@
+// Licensed to the Apache Software Foundation (ASF) und
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r495932581
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -997,173 +996,45 @@ object GroupMetadataManager {
val Metric
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r495940420
##
File path: core/src/main/resources/common/message/OffsetCommitRequest.json
##
@@ -0,0 +1,37 @@
+// Licensed to the Apache Software Foundation (ASF) unde
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r495940420
##
File path: core/src/main/resources/common/message/OffsetCommitRequest.json
##
@@ -0,0 +1,37 @@
+// Licensed to the Apache Software Foundation (ASF) unde
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r495966600
##
File path: core/src/main/resources/common/message/GroupMetadataResponse.json
##
@@ -0,0 +1,103 @@
+// Licensed to the Apache Software Foundation (ASF) u
ijuma commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r495973438
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms parameters
ijuma commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r495974098
##
File path: core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala
##
@@ -327,10 +327,12 @@ class DynamicBrokerConfigTest {
EasyMock.repla
mimaison commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r495975721
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static final
ijuma commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r495975325
##
File path:
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
##
@@ -2061,11 +2062,12 @@ class PlaintextAdminIntegrationTest ex
chia7712 commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r495983283
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms paramet
chia7712 commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r495983768
##
File path: core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala
##
@@ -327,10 +327,12 @@ class DynamicBrokerConfigTest {
EasyMock.re
ijuma commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r495988153
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms parameters
chia7712 commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r495992169
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms paramet
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r495995224
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r495995224
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r495995224
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
ijuma commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r496011734
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms parameters
chia7712 commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r496013137
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms paramet
tombentley commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r496048334
##
File path:
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
##
@@ -2061,11 +2062,12 @@ class PlaintextAdminIntegrationTe
[
https://issues.apache.org/jira/browse/KAFKA-10513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203342#comment-17203342
]
Boyang Chen commented on KAFKA-10513:
-
My understanding is that the consumer was sup
chia7712 commented on pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#issuecomment-700149221
rebase to trigger new QA
This is an automated message from the Apache Git Service.
To respond to the message, ple
ramesh-muthusamy commented on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-700171024
@kkonstantine can you help reviewing this PR
This is an automated message from the Apache Git Service.
rhauch commented on pull request #9306:
URL: https://github.com/apache/kafka/pull/9306#issuecomment-700182723
@shaikzakiriitm, you mentioned above:
> From v2.10.0 onwards, in jackson lib, ObjectMapper.readTree(input) started
to return JsonNode of type MISSING for empty input, as mentione
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10493:
-
Priority: Critical (was: Major)
> Ktable out-of-order updates are not being ignored
> -
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10493:
-
Fix Version/s: 3.0.0
> Ktable out-of-order updates are not being ignored
> -
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203430#comment-17203430
]
John Roesler commented on KAFKA-10493:
--
I've marked this for 3.0 so that we could c
rajinisivaram opened a new pull request #9345:
URL: https://github.com/apache/kafka/pull/9345
Adds support for SSL key and trust stores to be specified in PEM format
either as files or directly as configuration values.
### Committer Checklist (excluded from commit message)
- [ ] V
rajinisivaram commented on a change in pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#discussion_r496173659
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -1554,6 +1575,11 @@ private ConfigEntry configEntry(Cr
rajinisivaram merged pull request #9317:
URL: https://github.com/apache/kafka/pull/9317
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
vvcephei commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-700246317
Thanks, @MicahRam !
That failure looks unrelated: `Build / JDK 11 /
kafka.network.ConnectionQuotasTest.testNoConnectionLimitsByDefault`
--
vvcephei merged pull request #8181:
URL: https://github.com/apache/kafka/pull/8181
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
Vikas Singh created KAFKA-10531:
---
Summary: KafkaBasedLog can sleep for negative values
Key: KAFKA-10531
URL: https://issues.apache.org/jira/browse/KAFKA-10531
Project: Kafka
Issue Type: Bug
tahseen447 commented on pull request #5876:
URL: https://github.com/apache/kafka/pull/5876#issuecomment-700252065
just checking in, has this been resolved?
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/KAFKA-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vikas Singh reassigned KAFKA-10531:
---
Assignee: Vikas Singh
> KafkaBasedLog can sleep for negative values
> -
mjsax commented on pull request #9308:
URL: https://github.com/apache/kafka/pull/9308#issuecomment-700260093
Cherry-picked to `2.6`.
This is an automated message from the Apache Git Service.
To respond to the message, please
mjsax commented on pull request #9027:
URL: https://github.com/apache/kafka/pull/9027#issuecomment-700260133
Cherry-picked to `2.6`.
This is an automated message from the Apache Git Service.
To respond to the message, please
vvcephei commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-700274192
Cherry-picked to 2.6 and 2.5.
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-9584:
Fix Version/s: 2.6.1
2.5.2
2.7.0
> Removing headers causes Co
vvcephei opened a new pull request #9346:
URL: https://github.com/apache/kafka/pull/9346
Split up the ProcessorContext into separate containers more appropriate
for usage in `Processor#init` (`api.ProcessorContext`),
`StateStore#init` (`StateStoreContext`), and `Processor#process`
soondenana opened a new pull request #9347:
URL: https://github.com/apache/kafka/pull/9347
System.currentTimeMillis() is not monotonic, so using that to calculate
time to sleep can result in negative values. That will throw
IllegalArgumentException.
This change checks for that a
[
https://issues.apache.org/jira/browse/KAFKA-9370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203527#comment-17203527
]
Vikas Singh commented on KAFKA-9370:
https://github.com/apache/kafka/pull/9347
> Ret
[
https://issues.apache.org/jira/browse/KAFKA-9370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vikas Singh updated KAFKA-9370:
---
Comment: was deleted
(was: https://github.com/apache/kafka/pull/9347)
> Return UNKNOWN_TOPIC_OR_PART
splett2 commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496238384
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java
##
@@ -536,6 +536,22 @@ public void onCompletion(RecordMet
ijuma commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496240453
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -163,6 +163,18 @@ public void start() {
log.info(
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496263965
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -163,6 +163,18 @@ public void start() {
log.
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496267175
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -163,6 +163,18 @@ public void start() {
log.
ijuma commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496270581
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -163,6 +163,18 @@ public void start() {
log.info(
ijuma commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496270860
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -133,11 +134,14 @@ public void start() {
List par
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496271194
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java
##
@@ -536,6 +536,22 @@ public void onCompletion(Record
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496272243
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -163,6 +163,18 @@ public void start() {
log.
[
https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10455:
---
Assignee: Leah Thomas
> Probing rebalances are not guaranteed to be trigger
rhauch commented on a change in pull request #8910:
URL: https://github.com/apache/kafka/pull/8910#discussion_r496239771
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -138,6 +139,7 @@ public WorkerSinkTask(ConnectorTaskI
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496275381
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -133,11 +134,14 @@ public void start() {
Lis
vvcephei commented on a change in pull request #9346:
URL: https://github.com/apache/kafka/pull/9346#discussion_r496227502
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java
##
@@ -90,7 +90,7 @@ void register(final StateStore store,
Guozhang Wang created KAFKA-10532:
-
Summary: Do not wipe state store under EOS when closing a
RESTORING active or RUNNING standby task
Key: KAFKA-10532
URL: https://issues.apache.org/jira/browse/KAFKA-10532
[
https://issues.apache.org/jira/browse/KAFKA-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10532:
--
Summary: Do not wipe state store under EOS when closing-dirty a RESTORING
active or RUNNING st
[
https://issues.apache.org/jira/browse/KAFKA-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10532:
--
Description: Today whenever we are closing-dirty a task, we always wipe out
the state stores i
C0urante commented on a change in pull request #8910:
URL: https://github.com/apache/kafka/pull/8910#discussion_r446490310
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -689,6 +692,10 @@ else if (!context.pausedPartition
hachikuji commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r496287274
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms parame
rhauch merged pull request #8973:
URL: https://github.com/apache/kafka/pull/8973
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
rhauch commented on a change in pull request #8910:
URL: https://github.com/apache/kafka/pull/8910#discussion_r496239771
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -138,6 +139,7 @@ public WorkerSinkTask(ConnectorTaskI
rhauch commented on a change in pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#discussion_r496296182
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -260,7 +259,7 @@ private
[
https://issues.apache.org/jira/browse/KAFKA-9546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9546:
-
Labels: connect-api needs-kip (was: connect-api)
> Make FileStreamSourceTask extendable with gen
hachikuji merged pull request #9332:
URL: https://github.com/apache/kafka/pull/9332
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
hachikuji commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-700349997
@nym3r0s Take a look at
`SenderTest.testForceShutdownWithIncompleteTransaction`. I think we could add a
similar test which aborts the transaction directly before the Produce req
[
https://issues.apache.org/jira/browse/KAFKA-9546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203563#comment-17203563
]
Randall Hauch commented on KAFKA-9546:
--
[~galyo], thanks for the suggestion and the
rhauch commented on pull request #8134:
URL: https://github.com/apache/kafka/pull/8134#issuecomment-700351105
As noted on https://issues.apache.org/jira/browse/KAFKA-9546, I'm not
convinced this is useful change, since it would complicate these example
connectors that ship with AK and woul
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r496306298
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -283,49 +296,140 @@ public void tes
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r496306398
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -136,10 +141,19 @@ public void setu
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r496306777
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -283,49 +296,140 @@ public void tes
[
https://issues.apache.org/jira/browse/KAFKA-10511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10511.
-
Resolution: Fixed
> Fix minor behavior difference in `MockLog`
> ---
abbccdda commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496321312
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -1214,6 +1215,71 @@ default AlterClientQuotasResult
alterClientQuotas(
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496093216
##
File path: clients/src/main/resources/common/message/ApiVersionsResponse.json
##
@@ -55,8 +55,8 @@
"about": "The maximum supported version for
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r496326988
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -201,26 +213,24 @@ public void clos
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r496335557
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -201,26 +213,24 @@ public void clos
chia7712 commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r496340632
##
File path: docs/upgrade.html
##
@@ -27,6 +27,14 @@ Notable changes in 2
default.api.timeout.ms, and Kafka Streams' new
task.timeout.ms paramet
[
https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203601#comment-17203601
]
Chia-Ping Tsai commented on KAFKA-8266:
---
flaky again :(
https://ci-builds.apache.o
[
https://issues.apache.org/jira/browse/KAFKA-10530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203616#comment-17203616
]
John Roesler commented on KAFKA-10530:
--
Thanks for the report [~oweiler] , and sorr
[
https://issues.apache.org/jira/browse/KAFKA-10513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203622#comment-17203622
]
Guozhang Wang commented on KAFKA-10513:
---
[~mou@ea] could you try setting the `meta
hachikuji opened a new pull request #9348:
URL: https://github.com/apache/kafka/pull/9348
One of the invariants that the raft replication protocol attempts to ensure
is that each record is uniquely identified by leader epoch and offset. This can
be violated if a leader remains elected with
chia7712 opened a new pull request #9349:
URL: https://github.com/apache/kafka/pull/9349
add following checks to ```KafkaConsumer.groupMetadata```
1. null check of coordinator (replace NPE by ```InvalidGroupIdException```
which is same to other methods)
1. concurrent check (```gro
[
https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203648#comment-17203648
]
Or Shemesh commented on KAFKA-9220:
---
[~akumar] Go for it and take it:)
Thanks!!!
> Ti
98 matches
Mail list logo
