vinothchandar commented on issue #8462:
URL: https://github.com/apache/kafka/pull/8462#issuecomment-617567564
@guozhangwang So, I still need to add a test case around this specific
scenario, tasks stuck in created state.. Seems it needs some engineering to
create that scenario. (sophie
vinothchandar commented on a change in pull request #8462:
URL: https://github.com/apache/kafka/pull/8462#discussion_r412690139
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java
##
@@ -295,9 +295,10 @@ public void
jiamei xie created KAFKA-9901:
-
Summary: TimeoutError: Never saw message indicating StreamsTest
finished startup on ducker@ducker07
Key: KAFKA-9901
URL: https://issues.apache.org/jira/browse/KAFKA-9901
ijuma commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412680581
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,19 @@ import java.util.concurrent._
import
d8tltanc opened a new pull request #8528:
URL: https://github.com/apache/kafka/pull/8528
* Remove the --zookeeper flags for node versions supporting
--bootstrap-server for TopicCommand.
For the scram credential related code piece, switched to using
--bootstrap-server even we don't
ConcurrencyPractitioner commented on issue #7884:
URL: https://github.com/apache/kafka/pull/7884#issuecomment-617537261
test this please
This is an automated message from the Apache Git Service.
To respond to the
ConcurrencyPractitioner commented on issue #7884:
URL: https://github.com/apache/kafka/pull/7884#issuecomment-617537213
ok to test
This is an automated message from the Apache Git Service.
To respond to the message,
senthilm-ms commented on issue #8103:
URL: https://github.com/apache/kafka/pull/8103#issuecomment-617535197
@junrao @guozhangwang can you please review and let me know if you have any
more comments. would like to close and move on.
[
https://issues.apache.org/jira/browse/KAFKA-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-9900:
---
Attachment: leak3.jpg
> Expired Sensor can not be remove，and it fills all the old generation，can't be
> GC.
[
https://issues.apache.org/jira/browse/KAFKA-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-9900:
---
Description:
I tried kafka-client 2.1.0 and 2.1.1, but it exists both.
I found that ,lots of Sensor and
d8tltanc opened a new pull request #8527:
URL: https://github.com/apache/kafka/pull/8527
*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 testing
showuon commented on issue #8482:
URL: https://github.com/apache/kafka/pull/8482#issuecomment-617529478
@junrao @omkreddy , could you please help review this PR? This is a small
and straightforward change to update the documentation only, but I think it's
important to users. Thank you
apovzner commented on issue #8509:
URL: https://github.com/apache/kafka/pull/8509#issuecomment-617525619
@dajac Sounds good! I added unit tests to KafkaApisTest as you suggested.
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-9900:
---
Description:
I tried kafka-client 2.1.0 and 2.1.1, but it exists both.
I found that ,lots of Sensor and
[
https://issues.apache.org/jira/browse/KAFKA-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-9900:
---
Attachment: leak2.jpg
> Expired Sensor can not be remove，and it fills all the old generation，can't be
> GC.
[
https://issues.apache.org/jira/browse/KAFKA-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-9900:
---
Description:
!leak2.jpg|width=612,height=227!
!Leak1.jpg|width=354,height=286!
> Expired Sensor can not
[
https://issues.apache.org/jira/browse/KAFKA-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-9900:
---
Attachment: Leak1.jpg
> Expired Sensor can not be remove，and it fills all the old generation，can't be
> GC.
Chenxin created KAFKA-9900:
--
Summary: Expired Sensor can not be remove，and it fills all the old
generation，can't be GC.
Key: KAFKA-9900
URL: https://issues.apache.org/jira/browse/KAFKA-9900
Project: Kafka
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r412633489
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java
##
@@ -547,17 +547,15 @@ public void
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r412633349
##
File path: clients/src/test/java/org/apache/kafka/clients/MetadataTest.java
##
@@ -199,19 +200,21 @@ public void
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r412632269
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java
##
@@ -85,10 +85,6 @@ protected
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r412632493
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java
##
@@ -464,22 +466,41 @@ public static MetadataResponse
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r412632092
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -498,6 +498,104 @@ public void
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r412631698
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -498,6 +498,104 @@ public void
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r412631879
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -498,6 +498,104 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-2419:
---
Attachment: leak2.jpg
> Allow certain Sensors to be garbage collected after inactivity
>
[
https://issues.apache.org/jira/browse/KAFKA-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089231#comment-17089231
]
Chenxin commented on KAFKA-2419:
Execuse me. Is this bug fix now? I just see a ExpireSensorTask in
[
https://issues.apache.org/jira/browse/KAFKA-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-2419:
---
Attachment: Leak1.jpg
> Allow certain Sensors to be garbage collected after inactivity
>
[
https://issues.apache.org/jira/browse/KAFKA-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chenxin updated KAFKA-2419:
---
Attachment: Leak1
> Allow certain Sensors to be garbage collected after inactivity
>
iceChen8123 commented on issue #233:
URL: https://github.com/apache/kafka/pull/233#issuecomment-617512892
Execuse me. Is this bug fix now? I just see a ExpireSensorTask in Metrics,
but nowhere can use. Then I see beyond 800,000 sensors existed in my
application, and it is in Old
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089214#comment-17089214
]
Matthias J. Sax commented on KAFKA-8924:
{quote}there is no sensible default grace period
{quote}
[
https://issues.apache.org/jira/browse/KAFKA-9898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9898:
---
Component/s: unit tests
> Flaky Test
guozhangwang commented on issue #8462:
URL: https://github.com/apache/kafka/pull/8462#issuecomment-617488326
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on
andrewchoi5 commented on issue #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-617479063
Thanks for referring Matthias. Would appreciate your review @hachikuji
@cmccabe
This is an automated message from
Jeff Nadler created KAFKA-9899:
--
Summary: LogCleaner Tries To Clean Single Partition Over
1000x/Minute
Key: KAFKA-9899
URL: https://issues.apache.org/jira/browse/KAFKA-9899
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089107#comment-17089107
]
Sophie Blee-Goldman commented on KAFKA-7965:
Sophie Blee-Goldman created KAFKA-9898:
--
Summary: Flaky Test
StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores
Key: KAFKA-9898
URL: https://issues.apache.org/jira/browse/KAFKA-9898
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617439325
Unrelated java 11 failures:
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
[
https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089096#comment-17089096
]
Yuexi Liu commented on KAFKA-9335:
--
[~vveeramani] I test it, the 2.4.1 fixed it
>
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089090#comment-17089090
]
John Roesler commented on KAFKA-8924:
-
Thanks for the comment, [~cadonna] ,
I agree that it's not as
vvcephei commented on issue #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-617423885
I hope I didn't step on your toes, @ConcurrencyPractitioner , but I just
wanted to make sure that you're unblocked to finish up this PR. Figuring out
what's exactly wrong with those
vvcephei commented on issue #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-617423139
Ok, last one. The TransformValuesTest is just another case where the test
input data is now considered idempotent, which is fine:
```diff
---
vvcephei commented on issue #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-617418517
The source topic restart integration test was actually just failing because
the tests were polluting each others' topics. This is one way to fix it:
```diff
diff --git
[
https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089052#comment-17089052
]
Matthias J. Sax commented on KAFKA-9897:
[~NaviBrar] – would you be interested to look into this
vvcephei commented on issue #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-617392150
I also took a look at the foreign-key join test, which is actually telling
us something awesome: your feature allows us to drop _unnecessary_ tombstones
that we'd otherwise send under
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089016#comment-17089016
]
Jesse Anderson commented on KAFKA-9882:
---
Seeking each time was just an example. Adding a config
vvcephei commented on issue #8520:
URL: https://github.com/apache/kafka/pull/8520#issuecomment-617376010
Gah, I forgot to add the reviewers to the merge commit.
This is an automated message from the Apache Git Service.
To
surabhidixit opened a new pull request #8526:
URL: https://github.com/apache/kafka/pull/8526
*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
vvcephei commented on issue #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-617372772
Hey @ConcurrencyPractitioner , sorry it took so long. It's just again
because the test happened to expect idempotent updates to flow through
regularly, but not for anything important.
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089006#comment-17089006
]
Boyang Chen commented on KAFKA-9882:
So you are trying to reset offset every time when you restart
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617364803
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617364180
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ableegoldman commented on a change in pull request #8497:
URL: https://github.com/apache/kafka/pull/8497#discussion_r412424861
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ValidClientsByTaskLoadQueue.java
##
@@ -0,0 +1,108 @@
+/*
vvcephei commented on a change in pull request #8497:
URL: https://github.com/apache/kafka/pull/8497#discussion_r412424445
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ValidClientsByTaskLoadQueue.java
##
@@ -0,0 +1,108 @@
+/*
+ *
vvcephei commented on a change in pull request #8497:
URL: https://github.com/apache/kafka/pull/8497#discussion_r412423011
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ValidClientsByTaskLoadQueue.java
##
@@ -0,0 +1,110 @@
+/*
+ *
vvcephei commented on a change in pull request #8497:
URL: https://github.com/apache/kafka/pull/8497#discussion_r412422082
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java
##
@@ -16,128 +16,103 @@
*/
package
vvcephei commented on a change in pull request #8497:
URL: https://github.com/apache/kafka/pull/8497#discussion_r412419973
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java
##
@@ -16,128 +16,94 @@
*/
package
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088922#comment-17088922
]
Jesse Anderson commented on KAFKA-9882:
---
{code:java}
// Create KafkaConsumer and subscribe
// Call
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088917#comment-17088917
]
Boyang Chen commented on KAFKA-9882:
I see, to make the discussion more effective, could you draft a
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088908#comment-17088908
]
Jesse Anderson commented on KAFKA-9882:
---
subscribe() doesn't get a partition assignment until
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1708#comment-1708
]
Boyang Chen commented on KAFKA-9882:
I checked back on the original KIP
lbradstreet commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412313524
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,23 @@ import java.util.concurrent._
import
ijuma commented on a change in pull request #8417:
URL: https://github.com/apache/kafka/pull/8417#discussion_r412309101
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
##
@@ -57,6 +59,10 @@ public ByteBuffer serialize(ApiKeys apiKey,
lbradstreet commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412305902
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,23 @@ import java.util.concurrent._
import
mjsax commented on issue #8508:
URL: https://github.com/apache/kafka/pull/8508#issuecomment-617266065
Java 8 and Java 11 passed.
Java 14: failed with unknown error...
This is an automated message from the Apache Git
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617266153
Test this, please.
This is an automated message from the Apache Git Service.
To respond to the message, please log on
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617265836
Test this, please.
This is an automated message from the Apache Git Service.
To respond to the message, please log on
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617264248
Test this, please.
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HaiyuanZhao reassigned KAFKA-9850:
--
Assignee: HaiyuanZhao
> Move KStream#repartition operator validation during Topology build
tombentley commented on a change in pull request #8417:
URL: https://github.com/apache/kafka/pull/8417#discussion_r412287986
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
##
@@ -57,6 +59,10 @@ public ByteBuffer serialize(ApiKeys
chia7712 commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412284404
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,23 @@ import java.util.concurrent._
import
chia7712 commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412279368
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,24 @@ import java.util.concurrent._
import
avalsa commented on issue #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-61720
> I saw that the stream time update codepath is missing, could we add it
back? I was thinking about a simpler approach here: since we could not
decrement the stream-time, no matter we
dajac commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r412182105
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -1553,6 +1554,50 @@ class KafkaApisTest {
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412178952
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
##
@@ -179,6 +179,44 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088692#comment-17088692
]
Stanislav Kozlovski commented on KAFKA-9617:
Feel free to assign yourself [~showuon]!
>
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412178952
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
##
@@ -179,6 +179,44 @@ public void
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412178952
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
##
@@ -179,6 +179,44 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088647#comment-17088647
]
HaiyuanZhao commented on KAFKA-9850:
[~bchen225242]
I want to pick this up. Can u assign this to me?
dajac commented on issue #8509:
URL: https://github.com/apache/kafka/pull/8509#issuecomment-617137684
@apovzner Yeah, you're right. It does not increase the overall coverage.
I spent quite some time in the `KafkaApis` recently and I noticed that its
unit test coverage is quite low.
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412099165
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -115,7 +115,7 @@ public void suspend() {
}
cadonna commented on a change in pull request #8497:
URL: https://github.com/apache/kafka/pull/8497#discussion_r412047332
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ValidClientsByTaskLoadQueue.java
##
@@ -0,0 +1,106 @@
+/*
+ *
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412055008
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -305,6 +297,12 @@ public void resume() {
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412049922
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
##
@@ -1127,7 +1127,7 @@ public void
tombentley commented on issue #8311:
URL: https://github.com/apache/kafka/pull/8311#issuecomment-617069226
@dajac thanks for the review, I've addressed all your comments.
This is an automated message from the Apache Git
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412020510
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -93,6 +96,29 @@ long partitionTimestamp(final
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412020510
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -93,6 +96,29 @@ long partitionTimestamp(final
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412015236
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -50,7 +53,7 @@
*/
public class PartitionGroup
stanislavkozlovski commented on a change in pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#discussion_r412014026
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1066,6 +1066,7 @@ class KafkaController(val config: KafkaConfig,
dajac opened a new pull request #8525:
URL: https://github.com/apache/kafka/pull/8525
WIP
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
[
https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Ge reassigned KAFKA-9617:
--
Assignee: (was: Wang Ge)
> Replica Fetcher can mark partition as failed when max.message.bytes is
[
https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Ge reassigned KAFKA-9617:
--
Assignee: Wang Ge
> Replica Fetcher can mark partition as failed when max.message.bytes is changed
>
LiamClarkeNZ commented on a change in pull request #8520:
URL: https://github.com/apache/kafka/pull/8520#discussion_r412007274
##
File path: docs/streams/developer-guide/dsl-api.html
##
@@ -3262,12 +3262,15 @@ KTable-KTable
Foreign-Key
import
[
https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088442#comment-17088442
]
Bruno Cadonna commented on KAFKA-8924:
--
[~vvcephei] I like your proposal
{code:java}
public static
leonardge opened a new pull request #8524:
URL: https://github.com/apache/kafka/pull/8524
…ync.
*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.*
[
https://issues.apache.org/jira/browse/KAFKA-9781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fml2 updated KAFKA-9781:
Description:
TimestampConverter can convert a unix epoch value (long; number of milliseconds
since Jan 01 1970
[
https://issues.apache.org/jira/browse/KAFKA-9866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Ge reassigned KAFKA-9866:
--
Assignee: Wang Ge
> Do not attempt to elect preferred leader replicas which are outside ISR
>
[
https://issues.apache.org/jira/browse/KAFKA-9895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088354#comment-17088354
]
Boquan Tang commented on KAFKA-9895:
[~ijuma] We've only recently upgraded from 2.2.1 to 2.4.0, we
[
https://issues.apache.org/jira/browse/KAFKA-9895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088352#comment-17088352
]
Ismael Juma commented on KAFKA-9895:
Thanks for the report. Is there a reason you are using 2.4.0
99 matches
Mail list logo
