kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r498574911
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java
##
@@ -17,9 +17,16 @@
package org.apache.kafka.common.featu
mimaison commented on pull request #9281:
URL: https://github.com/apache/kafka/pull/9281#issuecomment-702608031
Test failures are not related, merging
This is an automated message from the Apache Git Service.
To respond to th
mimaison merged pull request #9281:
URL: https://github.com/apache/kafka/pull/9281
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
[
https://issues.apache.org/jira/browse/KAFKA-10478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10478.
Fix Version/s: 2.7.0
Resolution: Fixed
> advertised.listeners should allow duplicat
RamanVerma opened a new pull request #9364:
URL: https://github.com/apache/kafka/pull/9364
LogManager writes a clean shutdown file when the broker shuts down. The
presence of this file indicates that the broker had a clean shutdown and
log recovery is not needed upon the next boot up.
mimaison commented on pull request #9360:
URL: https://github.com/apache/kafka/pull/9360#issuecomment-702614729
Thanks @rajinisivaram for the review.
Test failures are not related, merging.
This is an automated message fro
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r498574911
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java
##
@@ -17,9 +17,16 @@
package org.apache.kafka.common.featu
[
https://issues.apache.org/jira/browse/KAFKA-10471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206053#comment-17206053
]
Raman Verma commented on KAFKA-10471:
-
PR available for review
https://github.com/ap
[
https://issues.apache.org/jira/browse/KAFKA-10471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raman Verma updated KAFKA-10471:
Comment: was deleted
(was: PR available for review
https://github.com/apache/kafka/pull/9364)
> T
mimaison merged pull request #9360:
URL: https://github.com/apache/kafka/pull/9360
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
[
https://issues.apache.org/jira/browse/KAFKA-10557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10557:
---
Affects Version/s: (was: 2.7.0)
> Missing docs when describing topic configs including d
mimaison commented on pull request #9360:
URL: https://github.com/apache/kafka/pull/9360#issuecomment-702617314
I'll also merge into 2.6
This is an automated message from the Apache Git Service.
To respond to the message, ple
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r498574911
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java
##
@@ -17,9 +17,16 @@
package org.apache.kafka.common.featu
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r498574911
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java
##
@@ -17,9 +17,16 @@
package org.apache.kafka.common.featu
kowshik commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-702621705
@junrao Thanks for the review comments! I have done the change proposed in
https://github.com/apache/kafka/pull/9001#discussion_r498574911 in the most
recent commit: 4218f95904989
kowshik edited a comment on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-702621705
@junrao Thanks for the review comments! I have done the change proposed in
https://github.com/apache/kafka/pull/9001#discussion_r498574911 in the most
recent commit: 4218f9
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r498574911
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java
##
@@ -17,9 +17,16 @@
package org.apache.kafka.common.featu
Tom Bentley created KAFKA-10566:
---
Summary: Erroneous unknown config warnings about ssl and sasl
configs
Key: KAFKA-10566
URL: https://issues.apache.org/jira/browse/KAFKA-10566
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-10557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10557.
Fix Version/s: 2.6.1
2.7.0
Resolution: Fixed
> Missing docs when
[
https://issues.apache.org/jira/browse/KAFKA-10557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10557:
---
Issue Type: Bug (was: Improvement)
> Missing docs when describing topic configs including d
dajac commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r498717745
##
File path: core/src/main/resources/common/message/OffsetCommitKey.json
##
@@ -0,0 +1,25 @@
+// Licensed to the Apache Software Foundation (ASF) under one o
[
https://issues.apache.org/jira/browse/KAFKA-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206122#comment-17206122
]
David Jacot commented on KAFKA-7383:
[~hachikuji] It seems that we have implemented t
shriram created KAFKA-10567:
---
Summary: Choose ip address while producing messages to kafka
broker.
Key: KAFKA-10567
URL: https://issues.apache.org/jira/browse/KAFKA-10567
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-10567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206129#comment-17206129
]
shriram commented on KAFKA-10567:
-
Gone through the API's which doesn't have any api to
rhauch commented on pull request #9306:
URL: https://github.com/apache/kafka/pull/9306#issuecomment-702745660
No green jobs, but all of the Connect and MirrorMaker2 tests in all of the
jobs passed. All of the failures in the tests were (flaky) client, broker, or
streams tests.
--
rhauch merged pull request #9306:
URL: https://github.com/apache/kafka/pull/9306
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
yeralin commented on pull request #6592:
URL: https://github.com/apache/kafka/pull/6592#issuecomment-702774321
@mjsax Let me know when I can jump back to it :)
This is an automated message from the Apache Git Service.
To resp
vvcephei commented on a change in pull request #9361:
URL: https://github.com/apache/kafka/pull/9361#discussion_r498871305
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -692,8 +690,7 @@ public boolean process(final long
rosibaj commented on pull request #8103:
URL: https://github.com/apache/kafka/pull/8103#issuecomment-702791679
@mjsax @junrao @guozhangwang is there a schedule for release of this feature?
This is an automated message from th
senthilm-ms commented on pull request #8103:
URL: https://github.com/apache/kafka/pull/8103#issuecomment-702793843
I will work on it in the coming week to close the code review…
Sorry for the delays!
Thanks,
Senthil
From: Rosi Bajari
Sent: Friday, October 2, 2020
nym3r0s commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-702794731
@hachikuji @ableegoldman - I've added a test for the same exception. Can you
pls take a look and let me know if any changes are needed?
-
Nikos Nikoloutsakos created KAFKA-10568:
---
Summary: transforms.InsertField.type
Key: KAFKA-10568
URL: https://issues.apache.org/jira/browse/KAFKA-10568
Project: Kafka
Issue Type: Bug
vvcephei commented on a change in pull request #9361:
URL: https://github.com/apache/kafka/pull/9361#discussion_r498904526
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java
##
@@ -55,6 +52,16 @@
*/
TaskId taskId();
+
vvcephei commented on a change in pull request #9361:
URL: https://github.com/apache/kafka/pull/9361#discussion_r498905668
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java
##
@@ -55,6 +52,16 @@
*/
TaskId taskId();
+
tombentley opened a new pull request #9365:
URL: https://github.com/apache/kafka/pull/9365
Fix warn log messages caused by making HashMap copies of configs prior to
using. This is not an ideal solution, but because the `Map`s are passed through
`Configurable.configure(Map)` it's not possib
tombentley commented on pull request #9365:
URL: https://github.com/apache/kafka/pull/9365#issuecomment-702817414
@rajinisivaram @omkreddy perhaps one of you could review?
This is an automated message from the Apache Git Serv
vvcephei commented on a change in pull request #9361:
URL: https://github.com/apache/kafka/pull/9361#discussion_r498914034
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -159,84 +157,123 @@ public StateStore get
vvcephei commented on a change in pull request #9361:
URL: https://github.com/apache/kafka/pull/9361#discussion_r498915601
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -159,84 +157,123 @@ public StateStore get
mimaison merged pull request #8730:
URL: https://github.com/apache/kafka/pull/8730
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
[
https://issues.apache.org/jira/browse/KAFKA-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10048:
---
Affects Version/s: 2.6.0
> Possible data gap for a consumer after a failover when using MM2
ning2008wisc commented on pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#issuecomment-702836102
Hi @mimaison I will rebase my pr https://github.com/apache/kafka/pull/9224
on top of this one over this weekend and hope you may have time soon to review
it as your next one.
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r498936138
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -998,173 +997,13 @@ object GroupMetadataManager {
val LoadTi
mimaison merged pull request #9341:
URL: https://github.com/apache/kafka/pull/9341
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
Petre Gordan created KAFKA-10569:
Summary: Running aggregate queries on KSQL client side is getting
to ERROR Shutdown broker because all log dirs in ...
Key: KAFKA-10569
URL: https://issues.apache.org/jira/browse/
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: ksql-server.properties
> Running aggregate queries on KSQL client side is getting to
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: server.properties
> Running aggregate queries on KSQL client side is getting to ERRO
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: zookeeper.properties
> Running aggregate queries on KSQL client side is getting to E
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: zookeeper-server-start.bat
> Running aggregate queries on KSQL client side is gettin
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: kafka-server-start.bat
> Running aggregate queries on KSQL client side is getting to
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: ksql-server-start
> Running aggregate queries on KSQL client side is getting to ERRO
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: ksql
> Running aggregate queries on KSQL client side is getting to ERROR Shutdown
>
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Description:
Working on Windows 10 and I'm running locally:
* in powershell, zookeeper with: *b
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Description:
Working on Windows 10 and confluent-5.5.0-2.12.zip and kafka_2.12-2.5.0. I'm
runni
[
https://issues.apache.org/jira/browse/KAFKA-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10564:
Labels: beginner newbie (was: )
> Continuous logging about deleting obsolete state direct
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petre Gordan updated KAFKA-10569:
-
Attachment: schema-registry.properties
> Running aggregate queries on KSQL client side is gettin
guozhangwang commented on a change in pull request #9361:
URL: https://github.com/apache/kafka/pull/9361#discussion_r498951242
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -159,84 +157,123 @@ public StateStore
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r498957874
##
File path: core/src/main/scala/kafka/common/OffsetAndMetadata.scala
##
@@ -45,8 +45,4 @@ object OffsetAndMetadata {
def apply(offset: Long, metadata:
vvcephei edited a comment on pull request #9346:
URL: https://github.com/apache/kafka/pull/9346#issuecomment-702209092
Closing POC in favor of new PR: https://github.com/apache/kafka/pull/9361
This is an automated message fro
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r498971069
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including a new RPC for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awk
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including a new RPC for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awk
dielhennr edited a comment on pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#issuecomment-683076305
Hey @jsancio ,
I added some work in progress to this branch including a new RPC for this
feature. Fitting user and client-id into the `DescribeConfigs` API was awk
rhauch commented on pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#issuecomment-702915039
@soondenana if the goal is to minimize the changes, would it be sufficient
to change the code to use `Time.sleep(...)` instead of `Thread.sleep(...)`, and
then change the `SystemTi
Xavier Léauté created KAFKA-10570:
-
Summary: Rename JMXReporter configs for KIP-629
Key: KAFKA-10570
URL: https://issues.apache.org/jira/browse/KAFKA-10570
Project: Kafka
Issue Type: Sub-task
Xavier Léauté created KAFKA-10571:
-
Summary: replace occurrences of blackout with backoff
Key: KAFKA-10571
URL: https://issues.apache.org/jira/browse/KAFKA-10571
Project: Kafka
Issue Type: Su
rhauch commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499023599
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -70,7 +70,7 @@
*/
public class KafkaBasedLog {
pr
[
https://issues.apache.org/jira/browse/KAFKA-10571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-10571:
--
Summary: replace occurrences of blackout with backoff for KIP-629 (was:
replace occurrences o
[
https://issues.apache.org/jira/browse/KAFKA-10572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-10572:
--
Summary: Rename mirrormaker 2 blacklist configs for KIP-629 (was: rename
mirrormaker 2 blackl
[
https://issues.apache.org/jira/browse/KAFKA-10571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-10571:
--
Summary: Replace occurrences of blackout with backoff for KIP-629 (was:
replace occurrences o
Xavier Léauté created KAFKA-10572:
-
Summary: rename mirrormaker 2 blacklist configs for KIP-629
Key: KAFKA-10572
URL: https://issues.apache.org/jira/browse/KAFKA-10572
Project: Kafka
Issue Ty
Xavier Léauté created KAFKA-10573:
-
Summary: Rename connect transform configs for KIP-629
Key: KAFKA-10573
URL: https://issues.apache.org/jira/browse/KAFKA-10573
Project: Kafka
Issue Type: Su
soondenana commented on pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#issuecomment-702938936
> @soondenana if the goal is to minimize the changes, would it be sufficient
to change the code to use `Time.sleep(...)` instead of `Thread.sleep(...)`, and
then change the `Sy
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499033230
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -133,11 +133,14 @@ public void start() {
Lis
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499033111
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -70,7 +70,7 @@
*/
public class KafkaBasedLog {
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r498959506
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,147 @@ class KafkaController(val config: KafkaConfig,
}
}
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r498980025
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,147 @@ class KafkaController(val config: KafkaConfig,
}
}
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499036138
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesResult.java
##
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Software F
rhauch commented on pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#issuecomment-702944802
> Considering that I decided to rewrite the loop to fix all three issues.
That makes sense, and I noticed the same when reviewing.
> Good question on performance. It se
xvrl opened a new pull request #9366:
URL: https://github.com/apache/kafka/pull/9366
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
[
https://issues.apache.org/jira/browse/KAFKA-10572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-10572:
--
Summary: Rename MirrorMaker 2 blacklist configs for KIP-629 (was: Rename
mirrormaker 2 blackl
[
https://issues.apache.org/jira/browse/KAFKA-10571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté reassigned KAFKA-10571:
-
Assignee: Xavier Léauté
> Replace occurrences of blackout with backoff for KIP-629
> --
[
https://issues.apache.org/jira/browse/KAFKA-10513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marlon Ou resolved KAFKA-10513.
---
Resolution: Won't Fix
> Newly added topic or partitions are not assigned to running consumer groups
junrao commented on a change in pull request #9364:
URL: https://github.com/apache/kafka/pull/9364#discussion_r499051238
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -244,7 +244,8 @@ class Log(@volatile private var _dir: File,
val producerIdExpirationC
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206536#comment-17206536
]
Matthias J. Sax commented on KAFKA-10569:
-
[~petregor...@gmail.com] – ksqlDB is
soondenana commented on pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#issuecomment-702979275
> should we also change Utils.sleep(...) (called by SystemTime.sleep(...)
that is now used above) to check and return immediately for a negative number
of milliseconds to sleep
xvrl opened a new pull request #9367:
URL: https://github.com/apache/kafka/pull/9367
* rename whitelist/blacklist to include/exclude
* add utility methods to translate deprecated configs
This is an automated message from t
ijuma commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499071998
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,11 @@ public static ByteBuffer wrapNullable(byte[] array) {
[
https://issues.apache.org/jira/browse/KAFKA-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté reassigned KAFKA-10570:
-
Assignee: Xavier Léauté
> Rename JMXReporter configs for KIP-629
>
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499076318
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,11 @@ public static ByteBuffer wrapNullable(byte[] array)
vvcephei commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r499019285
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -364,6 +368,62 @@ public void setUncaughtExceptionHandler(final
Threa
[
https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206551#comment-17206551
]
Almog Gavra commented on KAFKA-10569:
-
Hello [~petregor...@gmail.com] - I took a loo
ijuma commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499079604
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,11 @@ public static ByteBuffer wrapNullable(byte[] array) {
ijuma commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499079604
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,11 @@ public static ByteBuffer wrapNullable(byte[] array) {
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r499080376
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,11 @@ public static ByteBuffer wrapNullable(byte[] array)
vvcephei commented on pull request #9361:
URL: https://github.com/apache/kafka/pull/9361#issuecomment-703003770
One unrelated failure:
```
Build / JDK 11 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
failed
```
vvcephei merged pull request #9361:
URL: https://github.com/apache/kafka/pull/9361
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
guozhangwang commented on pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#issuecomment-703020271
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
guozhangwang commented on a change in pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#discussion_r499101848
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java
##
@@ -46,11 +46,22 @@ public void setStoreQue
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499102118
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesResult.java
##
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Software
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r499102266
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java
##
@@ -17,9 +17,16 @@
package org.apache.kafka.common.featu
1 - 100 of 111 matches
Mail list logo
