Gordon Wang created KAFKA-10252:
---
Summary: MeteredTimestampedKeyValueStore not setting up correct
topic name for GlobalKTable associating StateStores
Key: KAFKA-10252
URL: https://issues.apache.org/jira/browse/KAFKA
dajac opened a new pull request #8998:
URL: https://github.com/apache/kafka/pull/8998
Following https://github.com/apache/kafka/pull/8985, I have found another
case which incorrectly realised all futures when a failure occurs.
### Committer Checklist (excluded from commit message)
dajac commented on pull request #8998:
URL: https://github.com/apache/kafka/pull/8998#issuecomment-655961172
cc @cmccabe @ijuma
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154293#comment-17154293
]
Gordon Wang commented on KAFKA-10252:
-
Updated patch for fix.
> MeteredTimestampedK
dajac opened a new pull request #8999:
URL: https://github.com/apache/kafka/pull/8999
As pointed out by @ijuma in
https://github.com/apache/kafka/pull/8990#discussion_r451059876, using a `Set`
is not necessary as the caller only cares about having the list of timed out
connections/nodes.
rajinisivaram commented on a change in pull request #8999:
URL: https://github.com/apache/kafka/pull/8999#discussion_r452040424
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -443,13 +444,13 @@ public boolean isConnectionSetupTi
dajac commented on a change in pull request #8999:
URL: https://github.com/apache/kafka/pull/8999#discussion_r452052951
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -443,13 +444,13 @@ public boolean isConnectionSetupTimeout(St
omkreddy commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-656000189
@tombentley Thanks for the explanation. I will go ahead and merge the PR,
This is an automated message from the
omkreddy closed pull request #8966:
URL: https://github.com/apache/kafka/pull/8966
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
showuon commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-656008310
@omkreddy , sorry, I saw the PR is closed, instead of merging. Could you
please check again. Thanks.
This is an a
Konstantin Lalafaryan created KAFKA-10253:
-
Summary: Kafka Connect gets into a rebalance loop
Key: KAFKA-10253
URL: https://issues.apache.org/jira/browse/KAFKA-10253
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Lalafaryan updated KAFKA-10253:
--
Description:
Hello everyone!
We are running kafka-connect cluster (3 work
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Lalafaryan updated KAFKA-10253:
--
Description:
Hello everyone!
We are running kafka-connect cluster (3 work
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Lalafaryan updated KAFKA-10253:
--
Description:
Hello everyone!
We are running kafka-connect cluster (3 work
omkreddy edited a comment on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-656014523
@showuon I normally use `kafka-merge-pr.py` script for merging PRs. This
will do a direct push from local. In this case, github marks it as closed. You
can check the comm
omkreddy commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-656014523
@showuon I normally use `kafka-merge-pr.py` script for merging PRs. This
will do a direct push from local. In this case, github marks it as closed. You
can check the commit of t
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Lalafaryan updated KAFKA-10253:
--
Description:
Hello everyone!
We are running kafka-connect cluster (3 work
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Lalafaryan updated KAFKA-10253:
--
Summary: Kafka Connect gets into an infinite rebalance loop (was: Kafka
Conne
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Lalafaryan updated KAFKA-10253:
--
Component/s: KafkaConnect
> Kafka Connect gets into an infinite rebalance loop
showuon commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-656019261
Cool! Thanks, @omkreddy !
This is an automated message from the Apache Git Service.
To respond to the message, ple
omkreddy closed pull request #8808:
URL: https://github.com/apache/kafka/pull/8808
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-10109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-10109.
---
Fix Version/s: 2.7.0
Resolution: Fixed
Issue resolved by pull request 8808
[https://github.co
omkreddy commented on a change in pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#discussion_r452092180
##
File path:
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala
##
@@ -74,48 +75,58 @@ class SaslClientsWithInvalidCre
[
https://issues.apache.org/jira/browse/KAFKA-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154406#comment-17154406
]
Bruno Cadonna commented on KAFKA-10252:
---
Thank you for the bug report, [~bulbfreem
soarez opened a new pull request #9000:
URL: https://github.com/apache/kafka/pull/9000
Following up on #8752 which seems to have gone stale.
@mjsax can you continue the review?
This is an automated message from the Apa
akatona84 commented on a change in pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#discussion_r452108786
##
File path:
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala
##
@@ -74,48 +75,58 @@ class SaslClientsWithInvalidCr
akatona84 commented on a change in pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#discussion_r452108786
##
File path:
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala
##
@@ -74,48 +75,58 @@ class SaslClientsWithInvalidCr
akatona84 commented on pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#issuecomment-656038173
Thanks, @omkreddy for explaining how the consumers and prods are closed,
updated my PR so only closing things where it is necessary.
---
akatona84 edited a comment on pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#issuecomment-656038173
Thanks, @omkreddy for explaining how the consumers and prods are closed
(I've missed that), updated my PR so only closing things where it is necessary.
-
akatona84 commented on a change in pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#discussion_r452108786
##
File path:
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala
##
@@ -74,48 +75,58 @@ class SaslClientsWithInvalidCr
omkreddy commented on pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#issuecomment-656045969
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r452119998
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,24 +45,23 @@
protected Proces
kowshik opened a new pull request #9001:
URL: https://github.com/apache/kafka/pull/9001
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
[
https://issues.apache.org/jira/browse/KAFKA-10028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kowshik Prakasam reassigned KAFKA-10028:
Assignee: Kowshik Prakasam
> Implement write path for feature versioning scheme
>
omkreddy merged pull request #3480:
URL: https://github.com/apache/kafka/pull/3480
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
mimaison commented on pull request #8878:
URL: https://github.com/apache/kafka/pull/8878#issuecomment-656062630
@omkreddy @ijuma What's your opinion on this change? Currently a number of
config links collide and this is addressing it. However this will also break
existing links.
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r452140714
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -892,136 +894,175 @@ class KafkaApis(val requestChannel: RequestChannel,
def handle
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r452119998
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,24 +45,23 @@
protected Proces
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r452148874
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java
##
@@ -103,8 +104,12 @@ public void init(final Proce
[
https://issues.apache.org/jira/browse/KAFKA-10254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaotong.wang updated KAFKA-10254:
--
Description:
steps
1、start kafka broker
2、start kafka consumer and subscribe some topic wit
xiaotong.wang created KAFKA-10254:
-
Summary: 100% cpu usage by kafkaConsumer poll , when broker can‘t
be connect
Key: KAFKA-10254
URL: https://issues.apache.org/jira/browse/KAFKA-10254
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaotong.wang updated KAFKA-10254:
--
Description:
steps
1、start kafka broker
2、start kafka consumer and subscribe some topic wit
dajac commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r452162828
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software Found
dajac commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r452162969
##
File path: clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
##
@@ -97,7 +97,25 @@ public static RecordingLevel forName(String name) {
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r452165061
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -73,22 +73,23 @@
private final Set
dajac commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r452166182
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software Found
Luke Chen created KAFKA-10255:
-
Summary: Fix flaky testOneWayReplicationWithAutorOffsetSync1 test
Key: KAFKA-10255
URL: https://issues.apache.org/jira/browse/KAFKA-10255
Project: Kafka
Issue Type
omkreddy merged pull request #8992:
URL: https://github.com/apache/kafka/pull/8992
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 #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-656181031
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 #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-656181429
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
cmccabe opened a new pull request #9002:
URL: https://github.com/apache/kafka/pull/9002
Previously, we had some code hard-coded to generate message type classes
for RPCs. We might want to generate message type classes for other
things as well, so make it more generic.
--
Colin McCabe created KAFKA-10256:
Summary: Create a server gradle module for Java code needed only
by servers
Key: KAFKA-10256
URL: https://issues.apache.org/jira/browse/KAFKA-10256
Project: Kafka
joel-hamill commented on pull request #8878:
URL: https://github.com/apache/kafka/pull/8878#issuecomment-656205597
LGTM
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-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10240:
--
Description:
* When a task is scheduled for shutdown, the framework [wakes up the
consumer|ht
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r452324069
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -965,11 +994,11 @@ public void onFailure(RuntimeExcepti
junrao commented on pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#issuecomment-656214847
11 failures in system tests.
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-07-08--001.1594266883--chia7712--KAFKA-10235--a76224fff/report
[
https://issues.apache.org/jira/browse/KAFKA-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154702#comment-17154702
]
Chris Egerton commented on KAFKA-10240:
---
For some background: this was actually di
Jun Rao created KAFKA-10257:
---
Summary: system test
kafkatest.tests.core.security_rolling_upgrade_test fails
Key: KAFKA-10257
URL: https://issues.apache.org/jira/browse/KAFKA-10257
Project: Kafka
I
chia7712 commented on pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#issuecomment-656223017
> Did this PR fix transaction tests as expected?
Yep. core.transactions_test passes :)
This is an automate
junrao merged pull request #8981:
URL: https://github.com/apache/kafka/pull/8981
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-10235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10235.
-
Fix Version/s: 3.0.0
Resolution: Fixed
merged the PR to trunk.
> Fix flaky transactions_test.py
ijuma commented on a change in pull request #8999:
URL: https://github.com/apache/kafka/pull/8999#discussion_r452349346
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -443,13 +444,13 @@ public boolean isConnectionSetupTimeout(St
[
https://issues.apache.org/jira/browse/KAFKA-10254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154725#comment-17154725
]
Arvin Zheng commented on KAFKA-10254:
-
[~xiaotong.wang], see KAFKA-10134
> 100% cpu
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r452357020
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -215,7 +215,7 @@ public StateStore getGl
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r452365162
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -232,10 +232,16 @@ void initializeStoreO
[
https://issues.apache.org/jira/browse/KAFKA-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vinoth Chandar reassigned KAFKA-10131:
--
Assignee: Ron Dagostino (was: Vinoth Chandar)
> Minimize use of --zookeeper flag in
omkreddy commented on pull request #8878:
URL: https://github.com/apache/kafka/pull/8878#issuecomment-656246737
I agree, it's a useful fix. I think its OK to break existing links. I have
not seen anywhere using those links. Lets see what others think.
---
[
https://issues.apache.org/jira/browse/KAFKA-10174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154741#comment-17154741
]
Vinoth Chandar commented on KAFKA-10174:
[https://github.com/apache/kafka/pull/8
C0urante opened a new pull request #9003:
URL: https://github.com/apache/kafka/pull/9003
A benign `WakeupException` can be thrown by a sink task's consumer if it's
scheduled for shutdown by the worker. This is caught and handled gracefully if
the exception is thrown when calling `poll` on
C0urante commented on pull request #9003:
URL: https://github.com/apache/kafka/pull/9003#issuecomment-656247517
@gharris1727 @chia7712 @ncliang would any of you be interested in reviewing
this?
This is an automated message f
[
https://issues.apache.org/jira/browse/KAFKA-10235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-10235:
Fix Version/s: (was: 3.0.0)
2.7.0
> Fix flaky transactions_test.py
> --
[
https://issues.apache.org/jira/browse/KAFKA-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vinoth Chandar reassigned KAFKA-10213:
--
Assignee: Ron Dagostino (was: Vinoth Chandar)
> Prefer --bootstrap-server in ducktap
C0urante commented on pull request #8973:
URL: https://github.com/apache/kafka/pull/8973#issuecomment-656247489
@gharris1727 @chia7712 @ncliang would any of you be interested in reviewing
this?
This is an automated message f
vvcephei commented on pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#issuecomment-656247859
Looks like there was a spurious failure of the new test:
```
test_id:
kafkatest.tests.streams.streams_application_upgrade_test.StreamsUpgradeTest.test_app_upgrade.to_vers
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r452370517
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
##
@@ -104,17 +104,16 @@ static void closeState
vvcephei commented on pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#issuecomment-656249347
Ah, and the other smoke test usages are messed up:
```
test_id:
kafkatest.tests.streams.streams_eos_test.StreamsEosTest.test_rebalance_simple
status: FAIL
run t
Vinoth Chandar created KAFKA-10258:
--
Summary: Get rid of use_zk_connection flag in kafka.py public
methods
Key: KAFKA-10258
URL: https://issues.apache.org/jira/browse/KAFKA-10258
Project: Kafka
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r452372357
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void clo
vinothchandar commented on pull request #8948:
URL: https://github.com/apache/kafka/pull/8948#issuecomment-656251801
@cmccabe this PR is a sub task under KAFKA-10131, which tracks the bigger
goal. I filed a new issue explicitly targetting removal of `use_zk_connection`
. For this pr, the p
mimaison commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r452374925
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -994,30 +1023,29 @@ public void onSuccess(ClientRespons
ableegoldman commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r452381474
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -232,10 +232,16 @@ void initializeSt
mjsax commented on pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#issuecomment-656261242
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r452372357
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void clo
mjsax commented on pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#issuecomment-656261358
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r452372357
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void clo
cadonna commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-656263751
Unrelated test failure:
```
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
```
-
ableegoldman commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-656265143
Aw...the EosBetaUpgradeIntegrationTest failed again?? :/
This is an automated message from the Apache Git Se
mjsax commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r452391941
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,24 +45,23 @@
protected Processo
dajac commented on a change in pull request #8999:
URL: https://github.com/apache/kafka/pull/8999#discussion_r452393587
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -443,13 +444,13 @@ public boolean isConnectionSetupTimeout(St
mjsax commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r452394510
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java
##
@@ -103,8 +104,12 @@ public void init(final Process
ijuma commented on a change in pull request #8999:
URL: https://github.com/apache/kafka/pull/8999#discussion_r452395964
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -443,13 +444,13 @@ public boolean isConnectionSetupTimeout(St
ijuma commented on a change in pull request #8999:
URL: https://github.com/apache/kafka/pull/8999#discussion_r452396471
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -443,13 +444,13 @@ public boolean isConnectionSetupTimeout(St
dajac commented on a change in pull request #8999:
URL: https://github.com/apache/kafka/pull/8999#discussion_r452400759
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -443,13 +444,13 @@ public boolean isConnectionSetupTimeout(St
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-6453:
--
Assignee: James Galasyn (was: Victoria Bialas)
> Reconsider timestamp propagation sem
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6453:
---
Summary: Document timestamp propagation semantics (was: Reconsider
timestamp propagation sem
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6453:
---
Description:
Atm, Kafka Streams only has a defined "contract" about timestamp propagation at
mjsax commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r452408268
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -232,10 +232,16 @@ void initializeStoreOffs
mjsax commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r452410965
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -95,7 +96,7 @@
* | | Assigned (3
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154790#comment-17154790
]
Chris Egerton commented on KAFKA-10253:
---
[~klalafaryan] can you provide the config
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r452415850
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java
##
@@ -103,8 +104,12 @@ public void init(final Proce
1 - 100 of 166 matches
Mail list logo
