[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149170#comment-17149170
]
Manikumar commented on KAFKA-10220:
---
looks like this got introduced in [https://github
ijuma commented on pull request #7283:
URL: https://github.com/apache/kafka/pull/7283#issuecomment-652240876
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149192#comment-17149192
]
Tom Bentley commented on KAFKA-10220:
-
[~omkreddy] I'm happy to fix it, but Luke is
dajac commented on a change in pull request #8604:
URL: https://github.com/apache/kafka/pull/8604#discussion_r448178095
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -560,20 +561,18 @@ class LoggingMessageFormatter extends MessageFormatter
with Lazy
highluck closed pull request #8912:
URL: https://github.com/apache/kafka/pull/8912
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
highluck opened a new pull request #8965:
URL: https://github.com/apache/kafka/pull/8965
KAFKA-8147: Add changelog topic configuration to KTable suppress
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and
highluck commented on pull request #8965:
URL: https://github.com/apache/kafka/pull/8965#issuecomment-652259344
@mjsax
Should I do it like this way?
thank you!
This is an automated message from the Apache Git Service.
T
[
https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149206#comment-17149206
]
Luke Chen commented on KAFKA-10220:
---
[~tombentley], I'll submit a PR for your review l
huxihx created KAFKA-10222:
--
Summary: Incorrect methods show up in 0.10 Kafka Streams docs
Key: KAFKA-10222
URL: https://issues.apache.org/jira/browse/KAFKA-10222
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huxihx updated KAFKA-10222:
---
Description:
In 0.10 Kafka Streams
doc([http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/st
showuon opened a new pull request #8966:
URL: https://github.com/apache/kafka/pull/8966
Add null check for configurationKey to avoid NPE, and add test for it.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverag
showuon commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-652275690
@huxihx @tombentley , could you help review this PR? Thanks.
This is an automated message from the Apache Git Serv
skaundinya15 commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r448066943
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -74,22 +76,28 @@
private final ClusterResourceListeners clusterRe
tombentley commented on a change in pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#discussion_r448208882
##
File path: core/src/test/scala/unit/kafka/server/AdminManagerTest.scala
##
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
Rajini Sivaram created KAFKA-10223:
--
Summary: ReplicaNotAvailableException must be retriable to handle
reassignments
Key: KAFKA-10223
URL: https://issues.apache.org/jira/browse/KAFKA-10223
Project: K
showuon commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-652289242
hi @tombentley , thanks for the comments. I've updated in this commit:
https://github.com/apache/kafka/pull/8966/commits/ea249ab061fa2db7ba40963ff032c85a3919ecdb.
Thanks.
--
showuon commented on a change in pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#discussion_r448219612
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -355,8 +355,8 @@ class AdminManager(val config: KafkaConfig,
def createRespon
tombentley commented on a change in pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#discussion_r448222519
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -354,10 +354,13 @@ class AdminManager(val config: KafkaConfig,
}
de
[
https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149228#comment-17149228
]
ASF GitHub Bot commented on KAFKA-10222:
huxihx commented on pull request #272:
[
https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149227#comment-17149227
]
ASF GitHub Bot commented on KAFKA-10222:
huxihx opened a new pull request #272:
[
https://issues.apache.org/jira/browse/KAFKA-9247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149278#comment-17149278
]
Amit commented on KAFKA-9247:
-
Still having this issue : --
org.apache.zookeeper.ZooKeeper.m
showuon commented on a change in pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#discussion_r448262108
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -354,10 +354,13 @@ class AdminManager(val config: KafkaConfig,
}
def c
showuon commented on a change in pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#discussion_r448262108
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -354,10 +354,13 @@ class AdminManager(val config: KafkaConfig,
}
def c
[
https://issues.apache.org/jira/browse/KAFKA-9247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149278#comment-17149278
]
Amit edited comment on KAFKA-9247 at 7/1/20, 10:16 AM:
---
Still havin
[
https://issues.apache.org/jira/browse/KAFKA-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149298#comment-17149298
]
Viktor Utkin commented on KAFKA-10172:
--
Sure, sorry for delay, please give me some
[
https://issues.apache.org/jira/browse/KAFKA-9247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149299#comment-17149299
]
Ismael Juma commented on KAFKA-9247:
An old version of ZooKeeper in your classpath is
tombentley commented on pull request #7283:
URL: https://github.com/apache/kafka/pull/7283#issuecomment-652335281
All the test failures are in
`org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[false]`,
which looks to be unrelated. But I'
tombentley commented on pull request #7283:
URL: https://github.com/apache/kafka/pull/7283#issuecomment-652358496
@ijuma rebased, if you want to test again.
This is an automated message from the Apache Git Service.
To respond
omkreddy commented on pull request #8949:
URL: https://github.com/apache/kafka/pull/8949#issuecomment-652366530
ZK system tests passed. Merging to trunk and 2.6.
This is an automated message from the Apache Git Service.
To re
omkreddy closed pull request #8949:
URL: https://github.com/apache/kafka/pull/8949
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-10214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-10214.
---
Fix Version/s: 2.6.0
Resolution: Fixed
Issue resolved by pull request 8949
[https://github.co
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149437#comment-17149437
]
Bradley Peterson commented on KAFKA-9062:
-
I have just a question -- would these
omkreddy commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-652419884
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
vvcephei commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652423581
Looks like that one worked:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-07-01--001.1593607328--vvcephei--minor-vagrant-curl-retry--85
chia7712 commented on pull request #8944:
URL: https://github.com/apache/kafka/pull/8944#issuecomment-652435776
```
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[false]
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrat
showuon commented on a change in pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#discussion_r448393135
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -354,10 +354,12 @@ class AdminManager(val config: KafkaConfig,
}
def c
vvcephei commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-652450271
Looks like there are related failures:
```
org.apache.kafka.streams.processor.internals.StateDirectoryTest.shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked
org
VinceMu opened a new pull request #8967:
URL: https://github.com/apache/kafka/pull/8967
Work in progress, appreciate any feedback on my initial approach.
Adding a disconnect status to Kafka streams. This is achieved by introducing
by recording fetch disconnectedExceptions in Fetche
VinceMu commented on pull request #8967:
URL: https://github.com/apache/kafka/pull/8967#issuecomment-652464135
@mjsax @guozhangwang , would appreciate any feedback
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149490#comment-17149490
]
Vince Mu commented on KAFKA-6520:
-
Created a work in progress PR.
> When a Kafka Stream
[
https://issues.apache.org/jira/browse/KAFKA-9247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149509#comment-17149509
]
Amit edited comment on KAFKA-9247 at 7/1/20, 3:10 PM:
--
My ~/.bashrc
[
https://issues.apache.org/jira/browse/KAFKA-9247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149509#comment-17149509
]
Amit commented on KAFKA-9247:
-
My ~/.bashrc file i'm using ubuntu 20
i'm using apache-zookee
rhauch merged pull request #8858:
URL: https://github.com/apache/kafka/pull/8858
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-10153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10153:
--
Fix Version/s: 2.7.0
2.6.0
> Error Reporting in Connect Documentation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-10153.
---
Reviewer: Randall Hauch
Resolution: Fixed
> Error Reporting in Connect Documentation
>
rhauch commented on pull request #7496:
URL: https://github.com/apache/kafka/pull/7496#issuecomment-652482529
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
ableegoldman commented on pull request #8963:
URL: https://github.com/apache/kafka/pull/8963#issuecomment-652494651
EosBetaUpgradeIntegrationTest still failed a few times on the PR builds, but
it seems to be actual flakiness and not a new bug in eos-beta. I'll try and
tighten up the test a
abbccdda commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448457381
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -100,13 +100,19 @@ public InternalTopicMa
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149530#comment-17149530
]
Sophie Blee-Goldman commented on KAFKA-9062:
[~thebearmayor] I think you cou
abbccdda commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r448460197
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java
##
@@ -287,12 +290,124 @@ public void
shou
dajac opened a new pull request #8968:
URL: https://github.com/apache/kafka/pull/8968
TODO
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgra
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149532#comment-17149532
]
Sophie Blee-Goldman commented on KAFKA-9062:
Sorry, I didn't actually answer
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149541#comment-17149541
]
Bradley Peterson commented on KAFKA-9062:
-
[~ableegoldman] great, thanks. That bu
hachikuji commented on pull request #8934:
URL: https://github.com/apache/kafka/pull/8934#issuecomment-652518999
@guozhangwang Looks like the code is not compiling. I think you grabbed
`binaryExponentialElectionBackoffMs` from the Raft implementation, but we need
to initialize the max valu
hachikuji edited a comment on pull request #8934:
URL: https://github.com/apache/kafka/pull/8934#issuecomment-652518999
@guozhangwang Looks like the code is not compiling. I think you grabbed
`binaryExponentialElectionBackoffMs` from the prototype Raft implementation,
but we need to initia
[
https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9009:
---
Affects Version/s: 2.6.0
2.5.0
> Flaky Test
> kafka.integration.MetricsDuring
[
https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149560#comment-17149560
]
Boyang Chen commented on KAFKA-9009:
Failed
again:[https://builds.apache.org/job/kaf
andrewchoi5 commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r448505615
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,15 @@ class Partition(val topicPartition: TopicPartition,
add
abbccdda commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652554760
Failed tests should be non-related as we only change on system test run.
This is an automated message from the Ap
junrao commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r448527321
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,15 @@ class Partition(val topicPartition: TopicPartition,
addingRe
vvcephei commented on pull request #8961:
URL: https://github.com/apache/kafka/pull/8961#issuecomment-652566225
Thanks @kkonstantine and @abbccdda !
This is an automated message from the Apache Git Service.
To respond to the
vvcephei merged pull request #8961:
URL: https://github.com/apache/kafka/pull/8961
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
vvcephei commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-652566866
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
vvcephei commented on a change in pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#discussion_r448531033
##
File path: tests/kafkatest/services/streams.py
##
@@ -48,6 +48,15 @@ class StreamsTestBaseService(KafkaPathResolverMixin,
JmxMixin, Service):
vvcephei commented on pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#issuecomment-652572009
The existing `streams_upgrade_test.py` passes:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-07-01--001.1593623647--vvcephei--kafka-
guozhangwang commented on pull request #8934:
URL: https://github.com/apache/kafka/pull/8934#issuecomment-652573659
> @guozhangwang Looks like the code is not compiling. I think you grabbed
`binaryExponentialElectionBackoffMs` from the prototype Raft implementation,
but we need to initiali
guozhangwang commented on pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#issuecomment-652591278
> There's a bit of a chicken-and-egg problem here, since we can't add the
downgrade tests _yet_, but what I can do is to create the tickets to both fix
the known downgrade is
rhauch merged pull request #7496:
URL: https://github.com/apache/kafka/pull/7496
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-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9018.
--
Resolution: Fixed
> Kafka Connect - throw clearer exceptions on serialisation errors
>
Wavez opened a new pull request #8969:
URL: https://github.com/apache/kafka/pull/8969
fixed grammar
*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.*
*S
hachikuji opened a new pull request #8970:
URL: https://github.com/apache/kafka/pull/8970
Users often get confused after an unclean shutdown when log recovery takes a
long time. This patch attempts to make the logging clearer and provide a simple
indication of loading progress.
###
andrewchoi5 commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r448569922
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,15 @@ class Partition(val topicPartition: TopicPartition,
add
guozhangwang commented on a change in pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#discussion_r448569679
##
File path:
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
##
@@ -38,107 +37,128 @@
import org.apache.kafka.streams.kstr
jaredli2020 created KAFKA-10224:
---
Summary: The license term about jersey is not correct
Key: KAFKA-10224
URL: https://issues.apache.org/jira/browse/KAFKA-10224
Project: Kafka
Issue Type: Bug
vvcephei commented on a change in pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#discussion_r448581607
##
File path:
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
##
@@ -38,107 +37,128 @@
import org.apache.kafka.streams.kstream.
vvcephei commented on a change in pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#discussion_r448583306
##
File path: tests/kafkatest/services/streams.py
##
@@ -48,6 +48,15 @@ class StreamsTestBaseService(KafkaPathResolverMixin,
JmxMixin, Service):
vvcephei opened a new pull request #8971:
URL: https://github.com/apache/kafka/pull/8971
Most of the values in the metadata upgrade test matrix are just testing
the upgrade/downgrade path between two previous releases. This is
unnecessary. We run the tests for all supported branches, s
vvcephei commented on a change in pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#discussion_r448584762
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -189,54 +189,6 @@ def test_upgrade_downgrade_brokers(self, from_version,
to_vers
vvcephei commented on a change in pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#discussion_r448586796
##
File path: tests/kafkatest/tests/streams/streams_application_upgrade_test.py
##
@@ -0,0 +1,297 @@
+# Licensed to the Apache Software Foundation (ASF) un
ijuma opened a new pull request #8972:
URL: https://github.com/apache/kafka/pull/8972
This includes important fixes. Netty is required by ZooKeeper if TLS is
enabled.
I verified that the netty jars were changed from 4.1.48 to 4.1.50 with
this PR, `find . -name '*netty*'`:
rajinisivaram commented on pull request #8959:
URL: https://github.com/apache/kafka/pull/8959#issuecomment-652624512
@dajac @omkreddy @cmccabe Thanks for the review, merging to trunk.
This is an automated message from the Apa
rajinisivaram merged pull request #8959:
URL: https://github.com/apache/kafka/pull/8959
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
vvcephei commented on pull request #8971:
URL: https://github.com/apache/kafka/pull/8971#issuecomment-652625710
Oh, I realized this could plausibly impact the broker test also, so I kicked
off a test of the whole file:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4008/
vvcephei commented on a change in pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#discussion_r448598854
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -270,8 +270,11 @@ public void handleAssignment(fin
ableegoldman commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-652633092
Alright I checked this out and pulled in this fix to add retries to the
failing curl commands: let's give this yet another try:
https://jenkins.confluent.io/job/system-test-k
ableegoldman edited a comment on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-652633092
Alright I checked this out and pulled in [this
fix](https://github.com/apache/kafka/pull/8961) to add retries to the failing
curl commands: let's give this yet another
[
https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149702#comment-17149702
]
David Mollitor commented on KAFKA-4090:
---
[~adupriez] Any thoughts on this?
> JVM r
C0urante opened a new pull request #8973:
URL: https://github.com/apache/kafka/pull/8973
[Jira](https://issues.apache.org/jira/browse/KAFKA-10218)
We added a `canReadConfigs` field to the `DistributedHerder` a while back
that gets set to `false` if the herder fails to catch up to the
[
https://issues.apache.org/jira/browse/KAFKA-9893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjana Kaundinya resolved KAFKA-9893.
--
Resolution: Implemented
> Configurable TCP connection timeout and improve the initial m
[
https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjana Kaundinya reopened KAFKA-9678:
--
> Introduce bounded exponential backoff in clients
> --
[
https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjana Kaundinya resolved KAFKA-9678.
--
Resolution: Duplicate
> Introduce bounded exponential backoff in clients
>
guozhangwang commented on a change in pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#discussion_r448653507
##
File path: tests/kafkatest/tests/streams/streams_application_upgrade_test.py
##
@@ -0,0 +1,297 @@
+# Licensed to the Apache Software Foundation (ASF
guozhangwang commented on pull request #8938:
URL: https://github.com/apache/kafka/pull/8938#issuecomment-652681930
LGTM.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
omkreddy merged pull request #8969:
URL: https://github.com/apache/kafka/pull/8969
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 #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-652701636
> * Need to write the checkpoint when recycling a standby: although we do
preserve the changelog offsets when recycling a task, and should therefore
write the offsets when th
ableegoldman commented on a change in pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#discussion_r448680586
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -136,7 +143,59 @@ private boolean taskDirEm
guozhangwang commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-652708018
> 2\. But just opening a rocksdb store creates a `rocksdb` base dir in the
task directory, so the `taskDirIsEmpty` check always fails and we always throw
TaskCorrupted even i
ableegoldman commented on a change in pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#discussion_r448680662
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -136,7 +143,59 @@ private boolean taskDirEm
guozhangwang commented on pull request #8963:
URL: https://github.com/apache/kafka/pull/8963#issuecomment-652709044
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman commented on a change in pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#discussion_r448681797
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -270,8 +270,11 @@ public void handleAssignment
1 - 100 of 139 matches
Mail list logo
