[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170601#comment-17170601
]
Jerry Wei commented on KAFKA-10134:
---
The long time joining group is related to *max.po
johnthotekat opened a new pull request #9120:
URL: https://github.com/apache/kafka/pull/9120
*Deprecated the existing getters and added new getters `activeHost()`,
`standbyHosts()`, and `partition()` in KeyQueryMetadata.java.
*Updated the existing Tests to use the new getters of KeyQ
[
https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170636#comment-17170636
]
John Thomas commented on KAFKA-10316:
-
Thanks Matt. We've got 3 binding+1 , 3 non-bi
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r464884697
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -3973,25 +3977,38 @@ void handleResponse(AbstractResponse a
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r464886489
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java
##
@@ -47,96 +42,11 @@
public static final int CONSUMER_R
dajac commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r464911676
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -892,136 +894,175 @@ class KafkaApis(val requestChannel: RequestChannel,
def handleLis
[
https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170636#comment-17170636
]
John Thomas edited comment on KAFKA-10316 at 8/4/20, 9:26 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Thomas updated KAFKA-10316:
Remaining Estimate: 0h (was: 3h)
> Consider renaming getter method for Interactive Queries
>
showuon commented on pull request #9121:
URL: https://github.com/apache/kafka/pull/9121#issuecomment-668507540
@mjsax , could you review this PR to add tests? Thanks.
This is an automated message from the Apache Git Service.
showuon opened a new pull request #9121:
URL: https://github.com/apache/kafka/pull/9121
add 2 tests for IOExceptions cases:
1 for `OffsetCheckpoint` and 1 for `GlobalStateManagerImpl`
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
Eeranna Kuruva created KAFKA-10354:
--
Summary: Kafka Bug
Key: KAFKA-10354
URL: https://issues.apache.org/jira/browse/KAFKA-10354
Project: Kafka
Issue Type: Bug
Reporter: Eeranna K
nresare opened a new pull request #9122:
URL: https://github.com/apache/kafka/pull/9122
…irectories exist
Make sure that we set the isNew field in LeaderAndIsrRequest correctly for
brokers
that gets added to the replica set on reassignment.
This is tested by creating a vari
[
https://issues.apache.org/jira/browse/KAFKA-10314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170776#comment-17170776
]
Noa Resare commented on KAFKA-10314:
I just opened https://github.com/apache/kafka/p
[
https://issues.apache.org/jira/browse/KAFKA-10314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Noa Resare updated KAFKA-10314:
---
Flags: Patch
> KafkaStorageException on reassignment when offline log directories exist
> --
mumrah commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r465029352
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1771,6 +1775,127 @@ class KafkaController(val config: KafkaConfig,
}
dajac commented on a change in pull request #9114:
URL: https://github.com/apache/kafka/pull/9114#discussion_r465038411
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Founda
dajac commented on a change in pull request #9114:
URL: https://github.com/apache/kafka/pull/9114#discussion_r465038614
##
File path: core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala
##
@@ -131,6 +133,16 @@ class PermissiveControllerMutationQuota(private va
dajac commented on a change in pull request #9114:
URL: https://github.com/apache/kafka/pull/9114#discussion_r465040672
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Founda
dajac commented on a change in pull request #9114:
URL: https://github.com/apache/kafka/pull/9114#discussion_r465040813
##
File path: clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
##
@@ -223,8 +229,14 @@ public void checkQuotas(long timeMs) {
dajac commented on pull request #9114:
URL: https://github.com/apache/kafka/pull/9114#issuecomment-668593472
@junrao @apovzner I have updated the PR to address your comments. I have
also refactored the code a bit and updated all the tests of the controller
quota manager to work with the To
rhauch commented on pull request #9116:
URL: https://github.com/apache/kafka/pull/9116#issuecomment-668606283
Green builds on JDK 11 and 14, and two unrelated failures (known flaky
integration tests, not system tests) on JDK 8:
```
Test Result (2 failures / +1)
org.apache.kafk
rhauch edited a comment on pull request #9116:
URL: https://github.com/apache/kafka/pull/9116#issuecomment-668606283
Green builds on JDK 11 and 14, and two unrelated failures (known flaky
integration tests, not system tests) on JDK 8:
```
Test Result (2 failures / +1)
org.apac
[
https://issues.apache.org/jira/browse/KAFKA-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170805#comment-17170805
]
Ismael Juma commented on KAFKA-10353:
-
Looks like a duplicate of KAFKA-10308.
> Tro
ijuma commented on pull request #9079:
URL: https://github.com/apache/kafka/pull/9079#issuecomment-668607739
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
rhauch commented on pull request #9115:
URL: https://github.com/apache/kafka/pull/9115#issuecomment-668608342
Successful build on JDK 11. JDK 8 build timed out, and several test failures
on JDK 14.
Retest this please.
ijuma merged pull request #9079:
URL: https://github.com/apache/kafka/pull/9079
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
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465073439
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java
##
@@ -132,16 +135,19 @@
[
https://issues.apache.org/jira/browse/KAFKA-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski resolved KAFKA-10353.
-
Resolution: Duplicate
> Trogdor - Fix RoundTripWorker to not fail when the topic
[
https://issues.apache.org/jira/browse/KAFKA-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170819#comment-17170819
]
Stanislav Kozlovski commented on KAFKA-10353:
-
Should be fixed as of KAFKA-1
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465079294
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
##
@@ -0,0 +1,234 @@
+/*
+ * Licensed to the A
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465094963
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java
##
@@ -459,6 +460,95 @@ public void shouldGro
mjsax commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465097558
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java
##
@@ -132,16 +135,19 @@
mjsax commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465099913
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
##
@@ -0,0 +1,234 @@
+/*
+ * Licensed to the A
mjsax commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465101059
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
##
@@ -0,0 +1,234 @@
+/*
+ * Licensed to the A
mjsax commented on pull request #9121:
URL: https://github.com/apache/kafka/pull/9121#issuecomment-668639088
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
badaiaqrandista commented on a change in pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#discussion_r465105476
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -459,48 +466,32 @@ class DefaultMessageFormatter extends MessageFormatter
badaiaqrandista commented on a change in pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#discussion_r465105897
##
File path: core/src/test/scala/kafka/tools/DefaultMessageFormatterTest.scala
##
@@ -0,0 +1,235 @@
+/**
+ * Licensed to the Apache Software Found
mjsax commented on pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#issuecomment-668643155
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465106657
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -71,11 +75,40 @@ public HostInfo getActiveHost() {
* Get the St
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465111665
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java
##
@@ -0,0 +1,234 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10316:
Description:
In the 2.5 release, we introduce new classes for Interactive Queries via
KIP
[
https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10316:
Labels: beginner kip newbie (was: beginner need-kip newbie)
> Consider renaming getter me
[
https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10316:
Description:
In the 2.5 release, we introduce new classes for Interactive Queries via
KIP
junrao commented on a change in pull request #8936:
URL: https://github.com/apache/kafka/pull/8936#discussion_r465151900
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -652,6 +653,12 @@ class Log(@volatile private var _dir: File,
bytesTruncated
}
+ def s
johnthotekat commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465163841
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -71,11 +75,40 @@ public HostInfo getActiveHost() {
* Get
johnthotekat commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465164586
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -71,11 +75,40 @@ public HostInfo getActiveHost() {
* Get
johnthotekat commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465164267
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -71,11 +75,40 @@ public HostInfo getActiveHost() {
* Get
brary commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465176121
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -50,32 +50,65 @@ public KeyQueryMetadata(final HostInfo activeHost, f
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r465179335
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -369,6 +370,32 @@ class GroupCoordinator(val brokerId: Int,
}
johnthotekat commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465190512
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -50,32 +50,65 @@ public KeyQueryMetadata(final HostInfo active
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465191505
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java
##
@@ -459,6 +460,95 @@ public void shouldGro
johnthotekat commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465192381
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -50,32 +50,65 @@ public KeyQueryMetadata(final HostInfo active
johnthotekat commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465193230
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -50,32 +50,65 @@ public KeyQueryMetadata(final HostInfo active
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465193735
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/SlidingWindowsTest.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foun
lbradstreet opened a new pull request #9123:
URL: https://github.com/apache/kafka/pull/9123
When the consumer fetches a lot of partitions at once the isAvailable
check can become expensive due to a high number of contains check. We
might as well perform the isFetchable check first as t
johnthotekat commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465190512
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -50,32 +50,65 @@ public KeyQueryMetadata(final HostInfo active
lbradstreet commented on pull request #9123:
URL: https://github.com/apache/kafka/pull/9123#issuecomment-668711747
From a profile fetching from 2500 partitions. This section o
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465194845
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/SlidingWindowsTest.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software Foun
lbradstreet edited a comment on pull request #9123:
URL: https://github.com/apache/kafka/pull/9123#issuecomment-668711747
From a profile fetching from 2500 partitions. This se
Johnny-Malizia commented on a change in pull request #8936:
URL: https://github.com/apache/kafka/pull/8936#discussion_r465197854
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -652,6 +653,12 @@ class Log(@volatile private var _dir: File,
bytesTruncated
}
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r465200508
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -369,6 +370,32 @@ class GroupCoordinator(val brokerId: Int,
}
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170970#comment-17170970
]
Gokul Srinivas commented on KAFKA-10186:
[~ableegoldman], [~johnthotekat] Can I
brary commented on a change in pull request #9120:
URL: https://github.com/apache/kafka/pull/9120#discussion_r465201600
##
File path: streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
##
@@ -50,32 +50,65 @@ public KeyQueryMetadata(final HostInfo activeHost, f
[
https://issues.apache.org/jira/browse/KAFKA-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170971#comment-17170971
]
Boyang Chen commented on KAFKA-4587:
What's the status of this ticket? Do we still wa
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465205088
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java
##
@@ -221,7 +221,6 @@ public void shouldTransit
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r465206257
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -369,6 +370,32 @@ class GroupCoordinator(val brokerId: Int,
}
mjsax commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r465215487
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -326,13 +321,18 @@ bootstrap.serversstate.cleanup.delay.ms
Low
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r465219522
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java
##
@@ -459,6 +460,95 @@ public void shouldGro
chia7712 commented on pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#issuecomment-668732926
```org.apache.kafka.clients.admin.KafkaAdminClientTest.testMetadataRetries```
is traced by #9091 and
```EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]```
hachikuji commented on a change in pull request #9110:
URL: https://github.com/apache/kafka/pull/9110#discussion_r465221060
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2227,14 +2210,17 @@ class Log(@volatile private var _dir: File,
* @param segments The log
chia7712 commented on a change in pull request #8852:
URL: https://github.com/apache/kafka/pull/8852#discussion_r465229314
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -116,89 +112,100 @@ public boolean isValidTransition(fina
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171026#comment-17171026
]
Sophie Blee-Goldman commented on KAFKA-10186:
-
I was suggesting to throw a n
ableegoldman commented on pull request #9024:
URL: https://github.com/apache/kafka/pull/9024#issuecomment-668756679
1 unrelated failure: `SaslPlaintextConsumerTest.testCoordinatorFailover`
This is an automated message from th
abbccdda commented on a change in pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#discussion_r465243578
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -91,18 +100,20 @@ public InternalTopicMan
mjsax merged pull request #9024:
URL: https://github.com/apache/kafka/pull/9024
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
[
https://issues.apache.org/jira/browse/KAFKA-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171040#comment-17171040
]
Boyang Chen commented on KAFKA-10354:
-
What's this ticket about?
> Kafka Bug
>
dielhennr commented on a change in pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#discussion_r465257558
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -431,6 +433,26 @@ class AdminManager(val config: KafkaConfig,
(na
dielhennr commented on a change in pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#discussion_r465257558
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -431,6 +433,26 @@ class AdminManager(val config: KafkaConfig,
(na
Guozhang Wang created KAFKA-10355:
-
Summary: Handle accidental deletion of source-topics as
exceptional failure
Key: KAFKA-10355
URL: https://issues.apache.org/jira/browse/KAFKA-10355
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171047#comment-17171047
]
Gokul Srinivas commented on KAFKA-10186:
[~ableegoldman] Thank you, I'll keep ch
Guozhang Wang created KAFKA-10356:
-
Summary: Handle accidental deletion of sink-topics as exceptional
failure
Key: KAFKA-10356
URL: https://issues.apache.org/jira/browse/KAFKA-10356
Project: Kafka
junrao commented on a change in pull request #8936:
URL: https://github.com/apache/kafka/pull/8936#discussion_r465260977
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -652,6 +653,12 @@ class Log(@volatile private var _dir: File,
bytesTruncated
}
+ def s
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171051#comment-17171051
]
John Thomas commented on KAFKA-10186:
-
Thanks Sophie. I'll let Gokul work on it.
[~
Guozhang Wang created KAFKA-10357:
-
Summary: Handle accidental deletion of repartition-topics as
exceptional failure
Key: KAFKA-10357
URL: https://issues.apache.org/jira/browse/KAFKA-10357
Project: Ka
Randall Hauch created KAFKA-10358:
-
Summary: Remove the 2.12 sitedocs
Key: KAFKA-10358
URL: https://issues.apache.org/jira/browse/KAFKA-10358
Project: Kafka
Issue Type: Task
Compone
abbccdda opened a new pull request #9124:
URL: https://github.com/apache/kafka/pull/9124
The purpose of this PR is to both enhance the visibility of shutdown
progress for Kafka, as well as for the debugging purpose of a delayed process
in between socket server close and eventually kafka se
dajac closed pull request #9072:
URL: https://github.com/apache/kafka/pull/9072
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
[
https://issues.apache.org/jira/browse/KAFKA-10359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10359:
--
Summary: AgentTest unit test failure during verification build of AK 2.6.0
RC2 (was: Test fai
Randall Hauch created KAFKA-10359:
-
Summary: Test failure during verification build of AK 2.6.0 RC2
Key: KAFKA-10359
URL: https://issues.apache.org/jira/browse/KAFKA-10359
Project: Kafka
Issu
dajac commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r465272340
##
File path: clients/src/main/resources/common/message/RequestHeader.json
##
@@ -37,6 +37,12 @@
// Since the client is sending the ApiVersionsRequest in
dajac commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r465274018
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -2599,13 +2664,57 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
dajac commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r465273597
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -2453,34 +2455,98 @@ class KafkaApis(val requestChannel: RequestChannel,
def handleA
dajac commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r465273903
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -2599,13 +2664,57 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
ijuma merged pull request #9058:
URL: https://github.com/apache/kafka/pull/9058
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
ijuma commented on pull request #9058:
URL: https://github.com/apache/kafka/pull/9058#issuecomment-668778840
Merged to trunk. Is there a reason to backport it to older branches?
This is an automated message from the Apache Gi
dajac commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r465275440
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java
##
@@ -37,11 +37,22 @@ public RequestHeader(Struct struct, short head
dhruvilshah3 commented on a change in pull request #9110:
URL: https://github.com/apache/kafka/pull/9110#discussion_r464100823
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2227,14 +2210,17 @@ class Log(@volatile private var _dir: File,
* @param segments The
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171077#comment-17171077
]
Gokul Srinivas commented on KAFKA-10186:
Thank you [~johnthotekat]. Please assig
[
https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171078#comment-17171078
]
Sophie Blee-Goldman commented on KAFKA-10186:
-
[~nym3r0s] You need to send a
niteshmor commented on pull request #9058:
URL: https://github.com/apache/kafka/pull/9058#issuecomment-668789671
> Merged to trunk. Is there a reason to backport it to older branches?
Thank you.
I was under the impression that the older versions are bringing in a
vulnerable jackso
1 - 100 of 173 matches
Mail list logo
