mimaison commented on pull request #8921:
URL: https://github.com/apache/kafka/pull/8921#issuecomment-659272353
Test failure is unrelated:
-
org.apache.kafka.streams.integration.BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild
---
mimaison merged pull request #8921:
URL: https://github.com/apache/kafka/pull/8921
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-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10160.
Fix Version/s: 2.7.0
Resolution: Fixed
> Kafka MM2 consumer configuration
> ---
rajinisivaram commented on a change in pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#discussion_r455644987
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -712,10 +708,13 @@ class ReplicaManager(val config: KafkaConfig,
}
rajinisivaram commented on a change in pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#discussion_r455645402
##
File path:
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderOrFollowerException.java
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apac
rajinisivaram commented on pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#issuecomment-659288156
@hachikuji @ijuma Thanks for the reviews, have addressed the comments so far.
This is an automated message f
[
https://issues.apache.org/jira/browse/KAFKA-9973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159059#comment-17159059
]
zhangzhisheng commented on KAFKA-9973:
--
__consumer_offsets can not clean
kafka vers
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r455669663
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -892,136 +895,162 @@ class KafkaApis(val requestChannel: RequestChannel,
def handle
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r455671140
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -994,30 +1023,29 @@ public void onSuccess(ClientRespons
showuon opened a new pull request #9029:
URL: https://github.com/apache/kafka/pull/9029
In the original test, we will sleep for static 5 seconds to ensure the
automated group offset sync is complete. It sometimes synced fast (less than 1
sec), and sometimes slow (~ 20 seconds). I rewrite t
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r455671951
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1077,7 +1077,7 @@ class ReplicaManager(val config: KafkaConfig,
// Tr
showuon commented on a change in pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#discussion_r455672187
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -315,9 +319,34 @@ public void testRep
showuon commented on pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#issuecomment-659310965
@ning2008wisc @mimaison , could you help review this PR to fix the flaky
test? Thanks.
This is an automated messa
cadonna commented on a change in pull request #9027:
URL: https://github.com/apache/kafka/pull/9027#discussion_r455681362
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -181,6 +193,7 @@ bootstrap.serverscache.max.bytes.buffering
Medium
kaushik srinivas created KAFKA-10278:
Summary: kafka-configs does not show the current properties of
running kafka broker upon describe.
Key: KAFKA-10278
URL: https://issues.apache.org/jira/browse/KAFKA-10278
[
https://issues.apache.org/jira/browse/KAFKA-10278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159129#comment-17159129
]
kaushik srinivas commented on KAFKA-10278:
--
Hi [~rajinisiva...@gmail.com]
[~r
mimaison commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-659347339
Thanks @dajac for your comments, I've pushed an update.
@abbccdda Can you take a look?
This is an automate
rajinisivaram opened a new pull request #9030:
URL: https://github.com/apache/kafka/pull/9030
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including u
[
https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159164#comment-17159164
]
Ivan Ponomarev commented on KAFKA-5488:
---
Hi everyone,
{quote}I think there are som
[
https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Ponomarev reassigned KAFKA-5488:
-
Assignee: Ivan Ponomarev (was: highluck)
> KStream.branch should not return a Array of
[
https://issues.apache.org/jira/browse/KAFKA-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Ponomarev reassigned KAFKA-8296:
-
Assignee: Ivan Ponomarev
> Kafka Streams branch method raises type warnings
> --
[
https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159164#comment-17159164
]
Ivan Ponomarev edited comment on KAFKA-5488 at 7/16/20, 12:38 PM:
-
dajac commented on a change in pull request #9030:
URL: https://github.com/apache/kafka/pull/9030#discussion_r455745104
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -197,18 +197,20 @@
public class RequestResponseTest {
dajac commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r455763010
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -892,136 +895,162 @@ class KafkaApis(val requestChannel: RequestChannel,
def handleLis
dajac commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r455765374
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1077,7 +1077,7 @@ class ReplicaManager(val config: KafkaConfig,
// Try t
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r455782710
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1077,7 +1077,7 @@ class ReplicaManager(val config: KafkaConfig,
// Tr
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r455791789
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -892,136 +895,162 @@ class KafkaApis(val requestChannel: RequestChannel,
def handle
rondagostino commented on a change in pull request #9030:
URL: https://github.com/apache/kafka/pull/9030#discussion_r455792482
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java
##
@@ -66,10 +66,11 @@ public DescribeClientQuo
lbradstreet commented on a change in pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#discussion_r455828890
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
##
@@ -273,6 +99,28 @@ public boolean equals(Object o) {
lbradstreet commented on a change in pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#discussion_r455835380
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
##
@@ -273,6 +99,28 @@ public boolean equals(Object o) {
lbradstreet commented on a change in pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#discussion_r455835380
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
##
@@ -273,6 +99,28 @@ public boolean equals(Object o) {
[
https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159285#comment-17159285
]
highluck commented on KAFKA-5488:
-
@Ivan Ponomarev
thanks for comment!
Call me whenever y
rajinisivaram commented on a change in pull request #8933:
URL: https://github.com/apache/kafka/pull/8933#discussion_r455832706
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -295,34 +312,44 @@ class AdminManager(val config: KafkaConfig,
thro
vvcephei commented on a change in pull request #9027:
URL: https://github.com/apache/kafka/pull/9027#discussion_r455299303
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -181,6 +193,7 @@ bootstrap.serverscache.max.bytes.buffering
Medium
cmccabe commented on pull request #8948:
URL: https://github.com/apache/kafka/pull/8948#issuecomment-659508365
ok, that works for me. LGTM
This is an automated message from the Apache Git Service.
To respond to the message,
cmccabe merged pull request #8948:
URL: https://github.com/apache/kafka/pull/8948
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
[
https://issues.apache.org/jira/browse/KAFKA-10174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-10174.
--
Fix Version/s: 2.7
Reviewer: Colin McCabe
Resolution: Fixed
> Prefer --bootstr
ning2008wisc commented on a change in pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#discussion_r455902217
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -315,9 +319,34 @@ public void te
ning2008wisc commented on a change in pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#discussion_r455903116
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -315,9 +319,34 @@ public void te
vvcephei commented on a change in pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#discussion_r455904752
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java
##
@@ -20,62 +20,49 @@
import org.apache
ning2008wisc edited a comment on pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#issuecomment-659516303
Hi @showuon thanks for the fix, it looks a good start. Another minor and
non-blocking comment may be: if it is a small fix, probably 1 commit in the PR
looks more neat
ning2008wisc commented on pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#issuecomment-659516303
He @showuon thanks for the fix, it looks a good start. Another minor and
non-blocking comment may be: if it is a small fix, probably 1 commit in the PR
looks more neat.
---
[
https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159332#comment-17159332
]
Sophie Blee-Goldman commented on KAFKA-10205:
-
Given how many people have hi
rajinisivaram commented on a change in pull request #9030:
URL: https://github.com/apache/kafka/pull/9030#discussion_r455916021
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java
##
@@ -66,10 +66,11 @@ public DescribeClientQu
rajinisivaram commented on a change in pull request #9030:
URL: https://github.com/apache/kafka/pull/9030#discussion_r455916169
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -197,18 +197,20 @@
public class RequestRespons
vvcephei opened a new pull request #9031:
URL: https://github.com/apache/kafka/pull/9031
Just a POC for illustrative purposes. No need to review.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI buil
vinothchandar commented on pull request #8948:
URL: https://github.com/apache/kafka/pull/8948#issuecomment-659531282
Thanks @cmccabe
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman commented on a change in pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#discussion_r455916364
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -151,7 +151,7 @@ private void prepare
dima5rr commented on a change in pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#discussion_r455934580
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java
##
@@ -20,62 +20,49 @@
import org.apache.
dima5rr commented on a change in pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#discussion_r455939491
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java
##
@@ -46,11 +46,22 @@ public void setStoreQueryPar
vvcephei commented on a change in pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#discussion_r455948704
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java
##
@@ -51,18 +51,22 @@ public StreamThrea
[
https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159365#comment-17159365
]
Brian Forkan commented on KAFKA-10205:
--
[~mjsax] this fix appears to do the trick.
hachikuji commented on pull request #9011:
URL: https://github.com/apache/kafka/pull/9011#issuecomment-659560017
@guozhangwang There is one detail I think we're missing. If
`updateAssignmentMetadataIfNeeded` does not block, then execution will fall
through to `pollForFetches`. I would like
dima5rr commented on a change in pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#discussion_r455974476
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java
##
@@ -51,18 +51,22 @@ public StreamThread
[
https://issues.apache.org/jira/browse/KAFKA-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159387#comment-17159387
]
Sergey commented on KAFKA-10035:
Thanks!
> Improve the AbstractResetIntegrationTest
> -
[
https://issues.apache.org/jira/browse/KAFKA-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey updated KAFKA-10035:
---
Comment: was deleted
(was: Thanks!)
> Improve the AbstractResetIntegrationTest
> --
[
https://issues.apache.org/jira/browse/KAFKA-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159388#comment-17159388
]
Sergei commented on KAFKA-10035:
Thanks!
> Improve the AbstractResetIntegrationTest
> -
[
https://issues.apache.org/jira/browse/KAFKA-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159392#comment-17159392
]
Kowshik Prakasam commented on KAFKA-4620:
-
My observation is that it seems this i
bdbyrne commented on a change in pull request #9022:
URL: https://github.com/apache/kafka/pull/9022#discussion_r455998374
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
##
@@ -56,12 +56,17 @@ class TopicCommandWithAdminClientTest exten
hachikuji commented on a change in pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#discussion_r456008354
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
##
@@ -58,8 +58,8 @@
*
* - {@link Errors#OFFSET_OUT_OF_RANGE}
Rajini Sivaram created KAFKA-10279:
--
Summary: Allow dynamic update of certificates with additional
SubjectAltNames
Key: KAFKA-10279
URL: https://issues.apache.org/jira/browse/KAFKA-10279
Project: Kaf
hachikuji commented on pull request #9022:
URL: https://github.com/apache/kafka/pull/9022#issuecomment-659626413
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/KAFKA-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159436#comment-17159436
]
Maulin Vasavada commented on KAFKA-10279:
-
+1 Rajini.
> Allow dynamic update o
Raj created KAFKA-10280:
---
Summary: Message filtering support based on keys format/Headers
Key: KAFKA-10280
URL: https://issues.apache.org/jira/browse/KAFKA-10280
Project: Kafka
Issue Type: Improvement
jeffkbkim commented on a change in pull request #8935:
URL: https://github.com/apache/kafka/pull/8935#discussion_r456064275
##
File path: core/src/main/scala/kafka/controller/ControllerEventManager.scala
##
@@ -139,4 +140,19 @@ class ControllerEventManager(controllerId: Int,
serjchebotarev commented on a change in pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#discussion_r456067480
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -265,7 +265,7 @@ public void
shoul
serjchebotarev commented on a change in pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#discussion_r456067480
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -265,7 +265,7 @@ public void
shoul
serjchebotarev commented on a change in pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#discussion_r456068727
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -151,7 +151,7 @@ private void prepa
mumrah commented on pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#issuecomment-659665576
Updated the benchmarks with @lbradstreet's suggestions. Here are the results
for 3 partitions, 10 topics. GC profiles included.
On this branch:
```
Benchmark
mumrah edited a comment on pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#issuecomment-659665576
Updated the benchmarks with @lbradstreet's suggestions. Here are the results
for 3 partitions, 10 topics. GC profiles included.
On this branch:
```
Benchmark
ijuma commented on a change in pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#discussion_r456074355
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
##
@@ -139,13 +139,15 @@
InvalidFetchSizeException::new),
L
ijuma commented on pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#issuecomment-659670683
@rajinisivaram With regards to MetadataResponse, it's currently documented
as:
```
/**
* Possible topic-level error codes:
* UnknownTopic (3)
* LeaderNotAvail
lbradstreet commented on pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#issuecomment-659673793
> Updated the benchmarks with @lbradstreet's suggestions. Here are the
results for 3 partitions, 10 topics. GC profiles included.
>
> On this branch:
>
> ```
>
hachikuji commented on pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#issuecomment-659676133
I think it would make sense to change `ReplicaNotAvailableException` to
extend `InvalidMetadataException`.
This
hachikuji commented on a change in pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#discussion_r456076927
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java
##
@@ -16,5 +16,16 @@
*/
package org.apache.kafka.co
ijuma commented on a change in pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#discussion_r456091241
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java
##
@@ -16,5 +16,16 @@
*/
package org.apache.kafka.common
hachikuji commented on a change in pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#discussion_r456092037
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java
##
@@ -16,5 +16,16 @@
*/
package org.apache.kafka.co
ableegoldman commented on a change in pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#discussion_r456101096
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -265,7 +265,7 @@ public void
shouldN
vvcephei commented on pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#issuecomment-659701606
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#issuecomment-659701794
Ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
rondagostino opened a new pull request #9032:
URL: https://github.com/apache/kafka/pull/9032
*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.*
*Summary of test
Chris Beard created KAFKA-10281:
---
Summary: KIP-640: Add log compression analysis tool
Key: KAFKA-10281
URL: https://issues.apache.org/jira/browse/KAFKA-10281
Project: Kafka
Issue Type: Improvem
ableegoldman commented on pull request #9024:
URL: https://github.com/apache/kafka/pull/9024#issuecomment-659747346
Well it looks like we still get too many logs from the brokers even at INFO
level. I think we should just demote all broker logs to WARN and just bump it
back up to INFO if r
[
https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159570#comment-17159570
]
Viktor Utkin commented on KAFKA-9841:
-
Hi guys, will fix be back-ported to older vers
vutkin commented on pull request #8453:
URL: https://github.com/apache/kafka/pull/8453#issuecomment-659747738
Hi guys, will fix be back-ported to older versions of kafka?
This is an automated message from the Apache Git Servi
ableegoldman commented on a change in pull request #9027:
URL: https://github.com/apache/kafka/pull/9027#discussion_r456147419
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -181,6 +193,7 @@ bootstrap.serverscache.max.bytes.buffering
Medium
[
https://issues.apache.org/jira/browse/KAFKA-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Utkin updated KAFKA-10172:
-
Affects Version/s: 2.4.0
> [Kafka connect] connectors, tasks metrics doubled
> -
[
https://issues.apache.org/jira/browse/KAFKA-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159573#comment-17159573
]
Viktor Utkin commented on KAFKA-10172:
--
Looks like there is a bugfix: https://issue
ableegoldman commented on a change in pull request #9027:
URL: https://github.com/apache/kafka/pull/9027#discussion_r456148936
##
File path: docs/streams/developer-guide/running-app.html
##
@@ -110,6 +110,18 @@ Removing capacity
from your applicationIf a local state store exis
abbccdda commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-659752993
retest this
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Bob Barrett created KAFKA-10282:
---
Summary: Log metrics are removed if a log is deleted and
re-created quickly enough
Key: KAFKA-10282
URL: https://issues.apache.org/jira/browse/KAFKA-10282
Project: Kafk
Guozhang Wang created KAFKA-10283:
-
Summary: Consolidate client-level and consumer-level assignment
within ClientState
Key: KAFKA-10283
URL: https://issues.apache.org/jira/browse/KAFKA-10283
Project:
guozhangwang commented on pull request #9024:
URL: https://github.com/apache/kafka/pull/9024#issuecomment-659774428
@ableegoldman probably because the too much logs cause some of the
operations cannot be completed within the timeout; let's demote brokers to WARN
and I will trigger jenkins
guozhangwang commented on pull request #8997:
URL: https://github.com/apache/kafka/pull/8997#issuecomment-659775048
@abbccdda updated per your comments.
This is an automated message from the Apache Git Service.
To respond to
Boyang Chen created KAFKA-10284:
---
Summary: Group membership update due to static member rejoin
should be persisted
Key: KAFKA-10284
URL: https://issues.apache.org/jira/browse/KAFKA-10284
Project: Kafka
abbccdda commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-659793027
retest this
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159615#comment-17159615
]
Matthias J. Sax commented on KAFKA-10205:
-
[~ableegoldman] Good idea. Not everyb
[
https://issues.apache.org/jira/browse/KAFKA-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-8296.
Resolution: Duplicate
Closing this ticket as duplicate.
> Kafka Streams branch method rais
abbccdda commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-659793614
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159616#comment-17159616
]
Boyang Chen commented on KAFKA-10284:
-
[https://github.com/apache/kafka/blob/trunk/c
1 - 100 of 109 matches
Mail list logo
