dajac commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511746730
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4166,10 +4167,22 @@ public DescribeUserScramCredentialsResult
chia7712 opened a new pull request #9501:
URL: https://github.com/apache/kafka/pull/9501
This patch can reduce the elapsed time of testing
```TopicCommandWithAdminClientTest``` (5m19s -> 4m18s on my local)
### Committer Checklist (excluded from commit message)
- [ ] Verify des
Fleshgrinder commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511771687
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -4505,50 +4505,57 @@ public void testDescribeUserSc
Fleshgrinder commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511774755
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4166,10 +4167,22 @@ public DescribeUserScramCredential
Fleshgrinder commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511774755
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4166,10 +4167,22 @@ public DescribeUserScramCredential
chia7712 opened a new pull request #9502:
URL: https://github.com/apache/kafka/pull/9502
```StandbyTaskEOSIntegrationTest ```instantiates a
```EmbeddedKafkaCluster``` so it should be an ```IntegrationTest```.
### Committer Checklist (excluded from commit message)
- [ ] Verify desi
dajac commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511800360
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -4505,50 +4505,57 @@ public void testDescribeUserScramCred
dajac commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511804502
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4166,10 +4167,22 @@ public DescribeUserScramCredentialsResult
Fleshgrinder commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511806251
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -4505,50 +4505,57 @@ public void testDescribeUserSc
Fleshgrinder commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511810517
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4166,10 +4167,22 @@ public DescribeUserScramCredential
rajinisivaram commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r511842783
##
File path: core/src/main/scala/kafka/common/RecordValidationException.scala
##
@@ -23,5 +23,6 @@ import
org.apache.kafka.common.requests.ProduceRe
rajinisivaram commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r511872018
##
File path: core/src/main/scala/kafka/network/RequestChannel.scala
##
@@ -94,19 +104,63 @@ object RequestChannel extends Logging {
@volatile va
rajinisivaram commented on a change in pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#discussion_r511882563
##
File path: core/src/main/scala/kafka/controller/ControllerContext.scala
##
@@ -295,6 +316,10 @@ class ControllerContext {
topicsToBeDeleted -=
[
https://issues.apache.org/jira/browse/KAFKA-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming reassigned KAFKA-10644:
--
Assignee: dengziming
> Fix VotedToUnattached test error
>
>
dengziming created KAFKA-10644:
--
Summary: Fix VotedToUnattached test error
Key: KAFKA-10644
URL: https://issues.apache.org/jira/browse/KAFKA-10644
Project: Kafka
Issue Type: Sub-task
C
dengziming opened a new pull request #9503:
URL: https://github.com/apache/kafka/pull/9503
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
The method name is
dengziming commented on pull request #9503:
URL: https://github.com/apache/kafka/pull/9503#issuecomment-716508314
@hachikuji ,Hi, PTAL.
This is an automated message from the Apache Git Service.
To respond to the message, plea
dajac opened a new pull request #9504:
URL: https://github.com/apache/kafka/pull/9504
DescribeUserScramCredentialsRequest states that all users are described when
`Users` is empty or `null`. `null` is handled at the moment and throws an NPE.
### Committer Checklist (excluded from co
dajac commented on pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#issuecomment-716559206
FYI - I just opened a PR to fix the issue on the broker side:
https://github.com/apache/kafka/pull/9504.
This is an
Fleshgrinder commented on a change in pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#discussion_r511810517
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4166,10 +4167,22 @@ public DescribeUserScramCredential
Filippo Machi created KAFKA-10645:
-
Summary: Forwarding a record from a punctuator sometimes it
results in a NullPointerException
Key: KAFKA-10645
URL: https://issues.apache.org/jira/browse/KAFKA-10645
mumrah closed pull request #7265:
URL: https://github.com/apache/kafka/pull/7265
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
mumrah commented on pull request #7265:
URL: https://github.com/apache/kafka/pull/7265#issuecomment-716590142
@dajac yes, thanks for the ping on this. Closing
This is an automated message from the Apache Git Service.
To respo
[
https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Filippo Machi updated KAFKA-10645:
--
Description:
Hello,
I am working on a java kafka stream application (v. 2.5.0) running on a
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716607934
I was able to test this locally by setting the `mavenUrl` variable in
`~/.gradle/gradle.properties` file to `/Users/bill/Downloads/testRepo/` on my
laptop.
Running the `u
cmccabe commented on pull request #9504:
URL: https://github.com/apache/kafka/pull/9504#issuecomment-716610588
LGTM pending Jenkins. Thanks, @dajac .
This is an automated message from the Apache Git Service.
To respond to th
yuzawa-san commented on a change in pull request #9499:
URL: https://github.com/apache/kafka/pull/9499#discussion_r512045768
##
File path:
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java
##
@@ -119,7 +119,9 @@ public InputStream wrapForInput(ByteBuffe
yuzawa-san commented on pull request #9499:
URL: https://github.com/apache/kafka/pull/9499#issuecomment-716620712
@chia7712 @ijuma The main reason I'm holding off using the BufferSupplier
is because of part of the "after" benchmark looks like "before" benchmark:
```
Benchmark
ijuma commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716623972
What's in the following two files?
```text
-rw-r--r-- 1 bill staff 9585 Oct 26 10:47
./org/apache/kafka/kafka_2.12/2.8.0-SNAPSHOT/kafka_2.12-2.8.0-20201026.144723-1-s
ijuma commented on a change in pull request #9499:
URL: https://github.com/apache/kafka/pull/9499#discussion_r512054037
##
File path: gradle/dependencies.gradle
##
@@ -116,7 +116,7 @@ versions += [
testRetryPlugin: "1.1.6",
zinc: "1.3.5",
zookeeper: "3.5.8",
- zstd: "
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716627691
> What's in the following two files?
Just the manifest and the license
```
jar tf
./org/apache/kafka/kafka_2.13/2.8.0-SNAPSHOT/kafka_2.13-2.8.0-20201026.145017-1-
jolshan commented on a change in pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#discussion_r512054701
##
File path: core/src/main/scala/kafka/controller/ControllerContext.scala
##
@@ -126,6 +130,23 @@ class ControllerContext {
replicaStates.clear()
}
ijuma commented on a change in pull request #9499:
URL: https://github.com/apache/kafka/pull/9499#discussion_r512056003
##
File path: gradle/dependencies.gradle
##
@@ -116,7 +116,7 @@ versions += [
testRetryPlugin: "1.1.6",
zinc: "1.3.5",
zookeeper: "3.5.8",
- zstd: "
jolshan commented on a change in pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#discussion_r512056578
##
File path: core/src/main/scala/kafka/zk/KafkaZkClient.scala
##
@@ -481,43 +482,70 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient,
jolshan commented on a change in pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#discussion_r512068125
##
File path: core/src/main/scala/kafka/zk/KafkaZkClient.scala
##
@@ -577,6 +605,27 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, i
jolshan commented on a change in pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#discussion_r512069339
##
File path: core/src/main/scala/kafka/zk/KafkaZkClient.scala
##
@@ -616,7 +683,7 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, is
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716650023
@ijuma
This latest change gets us where I think want to be.
Using the same test procedure from before, we only have scaladoc files for
streams-scala
```
jolshan commented on a change in pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#discussion_r512081744
##
File path: core/src/main/scala/kafka/controller/ControllerContext.scala
##
@@ -295,6 +316,10 @@ class ControllerContext {
topicsToBeDeleted -= topic
bbejeck edited a comment on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716627691
> What's in the following two files?
Just the manifest and the license
```
jar tf
./org/apache/kafka/kafka_2.13/2.8.0-SNAPSHOT/kafka_2.13-2.8.0-20201026.14
bbejeck edited a comment on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716650023
@ijuma
This latest change gets us where I think we want to be.
Using the same test procedure from before, we only have scaladoc files for
streams-scala.
dajac commented on pull request #9374:
URL: https://github.com/apache/kafka/pull/9374#issuecomment-716659252
Test failures not related. Merging to trunk and 2.7.
This is an automated message from the Apache Git Service.
To re
dajac merged pull request #9374:
URL: https://github.com/apache/kafka/pull/9374
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
dajac commented on pull request #9504:
URL: https://github.com/apache/kafka/pull/9504#issuecomment-716664276
Test failures not related. Merging to trunk and 2.7.
This is an automated message from the Apache Git Service.
To re
dajac merged pull request #9504:
URL: https://github.com/apache/kafka/pull/9504
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
jsancio opened a new pull request #9505:
URL: https://github.com/apache/kafka/pull/9505
Adds the changes to Fetch and FetchSnapshot as describe in KIP-630.
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so
ijuma commented on a change in pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#discussion_r512140251
##
File path: build.gradle
##
@@ -731,6 +728,9 @@ project(':core') {
println "Building project 'core' with Scala version ${versions.scala}"
apply plug
[
https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220853#comment-17220853
]
Matthias J. Sax commented on KAFKA-10645:
-
`null` headers are actually not allow
bbejeck commented on a change in pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#discussion_r512145762
##
File path: build.gradle
##
@@ -731,6 +728,9 @@ project(':core') {
println "Building project 'core' with Scala version ${versions.scala}"
apply pl
Prateek Agarwal created KAFKA-10646:
---
Summary: Support dynamic config for "delete.topic.enable"
Key: KAFKA-10646
URL: https://issues.apache.org/jira/browse/KAFKA-10646
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Agarwal updated KAFKA-10646:
Description:
Topic deletion in Kafka removes data and the operation is not reversible (i.e
[
https://issues.apache.org/jira/browse/KAFKA-10646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Agarwal updated KAFKA-10646:
Description:
Topic deletion in Kafka removes data and the operation is not reversible (i.e
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716723668
updated this \cc @ijuma
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/KAFKA-10646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Harsha reassigned KAFKA-10646:
--
Assignee: Harsha
> Support dynamic config for "delete.topic.enable"
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10635:
--
Component/s: (was: streams)
producer
core
> Streams app
ijuma commented on a change in pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#discussion_r512178349
##
File path: build.gradle
##
@@ -731,6 +728,9 @@ project(':core') {
println "Building project 'core' with Scala version ${versions.scala}"
apply plug
hachikuji commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512189731
##
File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala
##
@@ -216,11 +216,9 @@ class KafkaNetworkChannel(time: Time,
endpoints.put(id
jsancio commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512195616
##
File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala
##
@@ -216,11 +216,9 @@ class KafkaNetworkChannel(time: Time,
endpoints.put(id,
hachikuji commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512196964
##
File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala
##
@@ -216,11 +216,9 @@ class KafkaNetworkChannel(time: Time,
endpoints.put(id
jsancio commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512195616
##
File path: core/src/main/scala/kafka/raft/KafkaNetworkChannel.scala
##
@@ -216,11 +216,9 @@ class KafkaNetworkChannel(time: Time,
endpoints.put(id,
hachikuji commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512217218
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -0,0 +1,294 @@
+/*
+ * Licensed to the Apache Software Found
hachikuji commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512224767
##
File path: raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java
##
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache Software Foundation
bbejeck commented on a change in pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#discussion_r512231724
##
File path: build.gradle
##
@@ -731,6 +728,9 @@ project(':core') {
println "Building project 'core' with Scala version ${versions.scala}"
apply pl
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716789180
updated this PR
\cc @ijuma
This is an automated message from the Apache Git Service.
To respond to the mes
ijuma commented on a change in pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#discussion_r512244515
##
File path: build.gradle
##
@@ -731,6 +728,9 @@ project(':core') {
println "Building project 'core' with Scala version ${versions.scala}"
apply plug
David Jacot created KAFKA-10647:
---
Summary: Only serialize owned partition when consumer protocol
version >= 0
Key: KAFKA-10647
URL: https://issues.apache.org/jira/browse/KAFKA-10647
Project: Kafka
dajac opened a new pull request #9506:
URL: https://github.com/apache/kafka/pull/9506
A regression got introduced by https://github.com/apache/kafka/pull/8897.
The owned partition field must be ignored for version < 1 otherwise the
serialization fails with an unsupported version exception.
[
https://issues.apache.org/jira/browse/KAFKA-10647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-10647:
Priority: Blocker (was: Major)
> Only serialize owned partition when consumer protocol version >=
[
https://issues.apache.org/jira/browse/KAFKA-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton closed KAFKA-10597.
-
> Still dealing issue with KAFKA-9066
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-10647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10647:
Fix Version/s: 2.7.0
> Only serialize owned partition when consumer protocol version >= 0
> -
guozhangwang merged pull request #9464:
URL: https://github.com/apache/kafka/pull/9464
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
guozhangwang commented on pull request #9464:
URL: https://github.com/apache/kafka/pull/9464#issuecomment-716859719
Cherry-picked to 2.7, cc @bbejeck
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/KAFKA-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10616.
---
Resolution: Fixed
> StreamThread killed by "IllegalStateException: The processor is already
junrao commented on a change in pull request #9364:
URL: https://github.com/apache/kafka/pull/9364#discussion_r512317288
##
File path: core/src/test/scala/unit/kafka/log/LogTest.scala
##
@@ -978,10 +1051,10 @@ class LogTest {
producerIdExpirationCheckIntervalMs = 3,
wcarlson5 commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r512320447
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -659,7 +727,6 @@ private KafkaStreams(final InternalTopologyBuilder
senthilm-ms commented on pull request #9495:
URL: https://github.com/apache/kafka/pull/9495#issuecomment-716884640
> @senthilm-ms : Thanks for the PR. When we log an exception, the cause of
the exception is logged too, right?
Yes, however as it is rethrowing new exception with generi
hachikuji commented on a change in pull request #9506:
URL: https://github.com/apache/kafka/pull/9506#discussion_r512344373
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java
##
@@ -46,6 +46,30 @@
private final TopicP
[
https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10642:
Fix Version/s: (was: 2.7.0)
2.8.0
> Expose the real stack trace if any exce
[
https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221051#comment-17221051
]
Bill Bejeck commented on KAFKA-10642:
-
Hi [~senthilm-ms], since this is not a blocke
[
https://issues.apache.org/jira/browse/KAFKA-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10641:
Fix Version/s: (was: 2.7.0)
2.8.0
> ACL Command hangs with SSL as not exist
[
https://issues.apache.org/jira/browse/KAFKA-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221052#comment-17221052
]
Bill Bejeck commented on KAFKA-10641:
-
Hi [~senthilm-ms], since this is not a blocke
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716904467
test failure unrelated and is a known flaky test
`org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]`
---
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716904890
Merged #9486 into trunk
This is an automated message from the Apache Git Service.
To respond to the message, pleas
bbejeck merged pull request #9486:
URL: https://github.com/apache/kafka/pull/9486
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
bbejeck commented on pull request #9486:
URL: https://github.com/apache/kafka/pull/9486#issuecomment-716905485
cherry-picked to 2.7
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-9381.
Resolution: Fixed
Resolved via [https://github.com/apache/kafka/pull/9486.]
Merged to trunk and
jiameixie commented on pull request #8446:
URL: https://github.com/apache/kafka/pull/8446#issuecomment-716921348
Call for review @huxihx
This is an automated message from the Apache Git Service.
To respond to the message,
chia7712 edited a comment on pull request #9499:
URL: https://github.com/apache/kafka/pull/9499#issuecomment-716935467
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
chia7712 commented on pull request #9499:
URL: https://github.com/apache/kafka/pull/9499#issuecomment-716935467
@yuzawa-san Thanks for great profile and explanation. I'm eager (too) to see
this patch to be merged since it not only improves the memory usage but also
brings better performanc
guozhangwang commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512389580
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -1605,100 +1708,18 @@ public void poll() throws IOException {
vamossagar12 commented on a change in pull request #9292:
URL: https://github.com/apache/kafka/pull/9292#discussion_r512396470
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -670,12 +675,16 @@ class GroupMetadataManager(brokerId: Int
guozhangwang commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512390308
##
File path: raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java
##
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache Software Foundat
chia7712 commented on a change in pull request #9506:
URL: https://github.com/apache/kafka/pull/9506#discussion_r512397607
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java
##
@@ -137,6 +161,19 @@ public void deserializeF
[
https://issues.apache.org/jira/browse/KAFKA-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-10628:
-
Assignee: Luke Chen
> Follow-up: Remove all unnecessary dummy TopologyTestDriver configs
>
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221144#comment-17221144
]
Leonardo Vasconcellos commented on KAFKA-7870:
--
Same thing here.
2020-10-2
showuon opened a new pull request #9507:
URL: https://github.com/apache/kafka/pull/9507
1. remove unneeded javadoc content.
2. Replace containsKey/setProperty with `putIfAbsent` (good refactor)
3. refactor the constructor of `TopologyTestDriverTest`
### Committer Checklist (excl
showuon commented on pull request #9507:
URL: https://github.com/apache/kafka/pull/9507#issuecomment-716985696
@chia7712 @vvcephei , could you review this PR? Thanks.
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221144#comment-17221144
]
Leonardo Vasconcellos edited comment on KAFKA-7870 at 10/27/20, 5:10 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221144#comment-17221144
]
Leonardo Vasconcellos edited comment on KAFKA-7870 at 10/27/20, 5:13 AM:
--
Sagar Rao created KAFKA-10648:
-
Summary: Add Prefix Scan support to State Stores
Key: KAFKA-10648
URL: https://issues.apache.org/jira/browse/KAFKA-10648
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221144#comment-17221144
]
Leonardo Vasconcellos edited comment on KAFKA-7870 at 10/27/20, 5:17 AM:
--
1 - 100 of 107 matches
Mail list logo
