[
https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286901#comment-17286901
]
Haruki Okada commented on KAFKA-12261:
--
Yeah, actually I've reconsidered about that and changed the
[
https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286892#comment-17286892
]
Luke Chen commented on KAFKA-12261:
---
I think we should document it, but not change the default setting
Arindam Ray created KAFKA-12346:
---
Summary: punctuate is called at twice the duration passed as the
first argument to Processor.Schedule (with PunctuationType.WALL_CLOCK_TIME)
Key: KAFKA-12346
URL:
[
https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-12261:
-
Description:
As of now, auto.offset.reset of ConsumerConfig is "latest" by default.
This
chia7712 commented on a change in pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#discussion_r578965629
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -366,6 +346,42 @@ private void readToLogEnd() {
[
https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-12261:
-
Assignee: Luke Chen
> Splitting partition causes message loss for consumers with
>
[
https://issues.apache.org/jira/browse/KAFKA-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-12273:
---
Fix Version/s: 3.0.0
> InterBrokerSendThread#pollOnce throws FatalExitError even though it
[
https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
GeordieMai reassigned KAFKA-12336:
--
Assignee: GeordieMai
> custom stream naming does not work while calling stream[K,
tinawenqiao commented on pull request #9235:
URL: https://github.com/apache/kafka/pull/9235#issuecomment-781848357
> Thanks for the PR @tinawenqiao.
>
> It would be nice to also mention `rest.port` and `rest.host.name` are
deprecated in their descriptions. Could you add something
mjsax commented on pull request #10072:
URL: https://github.com/apache/kafka/pull/10072#issuecomment-781840391
Updated.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
mjsax commented on a change in pull request #10072:
URL: https://github.com/apache/kafka/pull/10072#discussion_r578937359
##
File path: streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
##
@@ -32,6 +33,7 @@
public final int topicGroupId;
/** The ID
hachikuji commented on pull request #10157:
URL: https://github.com/apache/kafka/pull/10157#issuecomment-781825379
> Okay. I guess we need another KIP that explains how to upgrade a cluster
and to determine when it is safe to enable the RaftClient on all of the brokers
of a cluster.
rhauch commented on pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#issuecomment-781813200
@chia7712, for what it's worth, I still think your #10152 PR is still an
important fix.
This is an automated
rhauch commented on pull request #10152:
URL: https://github.com/apache/kafka/pull/10152#issuecomment-781812825
Thanks, @chia7712. I've reviewed much of this, and it seems straightforward,
though I plan to review more thoroughly tomorrow (~12 hours). I've asked a few
others that might be
rhauch commented on a change in pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#discussion_r578916881
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -390,7 +410,11 @@ public void run() {
rhauch commented on a change in pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#discussion_r578919850
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -366,6 +348,44 @@ private void readToLogEnd() {
rhauch commented on pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#issuecomment-781810306
Thanks for the quick review, @chia7712. I've incorporated several of your
suggestions, and added comments/responses on the others.
BTW, a run of the relevant Connect
rhauch commented on a change in pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#discussion_r578917177
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -366,6 +348,44 @@ private void readToLogEnd() {
rhauch commented on a change in pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#discussion_r578916881
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -390,7 +410,11 @@ public void run() {
chia7712 merged pull request #10154:
URL: https://github.com/apache/kafka/pull/10154
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
chia7712 commented on pull request #10154:
URL: https://github.com/apache/kafka/pull/10154#issuecomment-781801914
run `downgrade_test` with this patch on my local. pass
will merge this patch to trunk and 2.8
This is
hachikuji commented on pull request #10157:
URL: https://github.com/apache/kafka/pull/10157#issuecomment-781799540
@jsancio I may be misunderstanding your question, but api versions are
negotiated internally in `NetworkClient`. If there are no compatible versions,
then the client will
chia7712 commented on a change in pull request #10158:
URL: https://github.com/apache/kafka/pull/10158#discussion_r578907382
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -366,6 +348,44 @@ private void readToLogEnd() {
dengziming commented on pull request #10147:
URL: https://github.com/apache/kafka/pull/10147#issuecomment-781799200
@guozhangwang @hachikuji , Hello, PTAL.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-12258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12258.
-
Resolution: Fixed
> Change the BatchAccumulator to split records into batches
>
hachikuji merged pull request #10063:
URL: https://github.com/apache/kafka/pull/10063
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
jsancio commented on pull request #10063:
URL: https://github.com/apache/kafka/pull/10063#issuecomment-781790693
The following tests failed:
```
core:
ConfigCommandTest. shouldFailIfUnresolvableHost()
ConfigCommandTest. shouldFailIfUnresolvableHost()
jsancio commented on pull request #10157:
URL: https://github.com/apache/kafka/pull/10157#issuecomment-781784110
> We do not plan to rely on the IBP in order to determine API versions for
raft requests. Instead, we want to discover them through the ApiVersions API.
This patch enables the
dengziming opened a new pull request #10159:
URL: https://github.com/apache/kafka/pull/10159
*More detailed description of your change*
The logics are duplicated except that `MetadataRecordSerde` has an extra
`DEFAULT_FRAME_VERSION`, if we want to change the serial/deserial format of
jsancio commented on pull request #10063:
URL: https://github.com/apache/kafka/pull/10063#issuecomment-781778478
Running the following commands
```
./gradlew -version
Gradle 6.8.1
mjsax commented on pull request #10091:
URL: https://github.com/apache/kafka/pull/10091#issuecomment-781777265
Thanks for the PR @MarcoLotz! And congrats to your first code contribution!
Thanks for reviewing @vcrfxia!
Merged to `trunk` and cherry-picked to `2.8` branch.
[
https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9524.
Fix Version/s: 2.8.0
Resolution: Fixed
> Default window retention does not consider
[
https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9524:
---
Issue Type: Improvement (was: Bug)
> Default window retention does not consider grace
rhauch opened a new pull request #10158:
URL: https://github.com/apache/kafka/pull/10158
Refactored the KafkaBasedLog logic to read end offsets into a separate
method to make it easier to test. Also changed the TopicAdmin.endOffsets method
to throw the original
jsancio commented on a change in pull request #10063:
URL: https://github.com/apache/kafka/pull/10063#discussion_r578886362
##
File path: raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java
##
@@ -307,4 +309,38 @@ public int writeRecord(
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alok Nikhil updated KAFKA-12345:
Affects Version/s: 2.8.0
> KIP-500: AlterIsrManager crashes on broker idle-state
>
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286821#comment-17286821
]
Alok Nikhil commented on KAFKA-12345:
-
Hi [~dengziming]. I have updated the Kafka version and the
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alok Nikhil updated KAFKA-12345:
Priority: Minor (was: Major)
> KIP-500: AlterIsrManager crashes on broker idle-state
>
showuon edited a comment on pull request #10118:
URL: https://github.com/apache/kafka/pull/10118#issuecomment-781768574
> Fine by me, flaky tests suck.
Indeed! Thanks, @C0urante
@kkonstantine , could you check this PR? Thanks.
hachikuji commented on a change in pull request #10129:
URL: https://github.com/apache/kafka/pull/10129#discussion_r578873790
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
##
@@ -354,7 +355,8 @@
"Requested position is not greater
showuon commented on pull request #10118:
URL: https://github.com/apache/kafka/pull/10118#issuecomment-781768574
> Fine by me, flaky tests suck.
Indeed! Thanks, @C0urante
@kkonstantine , could you check this PR? Thanks.
hachikuji opened a new pull request #10157:
URL: https://github.com/apache/kafka/pull/10157
We do not plan to rely on the IBP in order to determine API versions for
raft requests. Instead, we want to discover them through the ApiVersions API.
This patch enables the flag to do so.
junrao commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r578876029
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
##
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the Apache Software
mjsax merged pull request #10091:
URL: https://github.com/apache/kafka/pull/10091
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
hachikuji commented on a change in pull request #10129:
URL: https://github.com/apache/kafka/pull/10129#discussion_r578873790
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
##
@@ -354,7 +355,8 @@
"Requested position is not greater
hachikuji commented on a change in pull request #10129:
URL: https://github.com/apache/kafka/pull/10129#discussion_r578876834
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -1751,6 +1768,7 @@ private FetchRequestData buildFetchRequest() {
dengziming commented on pull request #10021:
URL: https://github.com/apache/kafka/pull/10021#issuecomment-781762837
ping @hachikuji .
retest this, please.
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286815#comment-17286815
]
dengziming edited comment on KAFKA-12345 at 2/19/21, 2:02 AM:
--
hello,
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286815#comment-17286815
]
dengziming commented on KAFKA-12345:
hello, please provide your specified Kafka version, or the
hachikuji commented on a change in pull request #10063:
URL: https://github.com/apache/kafka/pull/10063#discussion_r578870759
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -298,28 +342,30 @@ public void close() {
public
hachikuji commented on a change in pull request #10063:
URL: https://github.com/apache/kafka/pull/10063#discussion_r578870321
##
File path: raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java
##
@@ -307,4 +309,38 @@ public int writeRecord(
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286810#comment-17286810
]
Alok Nikhil commented on KAFKA-12345:
-
Adding a bit more context. Seems like there was a controller
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alok Nikhil updated KAFKA-12345:
Description:
Occasionally, a scheduler thread on a broker crashes with this stack
{code:java}
[
https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286808#comment-17286808
]
Guozhang Wang commented on KAFKA-10847:
---
[~spena][~vcrfxia][~mjsax] I'd like to dump some more
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alok Nikhil updated KAFKA-12345:
Description:
Occasionally, a scheduler thread on a broker crashes with this stack
```
Alok Nikhil created KAFKA-12345:
---
Summary: KIP-500: AlterIsrManager crashes on broker idle-state
Key: KAFKA-12345
URL: https://issues.apache.org/jira/browse/KAFKA-12345
Project: Kafka
Issue
cmccabe commented on pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#issuecomment-781745956
> I think we need to handle preferred leader election in a special way. For
example, if the assigned replicas are 1,2,3, isr is 2,3 and the current leader
is 3, when doing
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r578857828
##
File path:
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java
##
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-12232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12232.
-
Resolution: Duplicate
> Distinguish API scope by broker/controller
>
[
https://issues.apache.org/jira/browse/KAFKA-12278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286803#comment-17286803
]
Jason Gustafson commented on KAFKA-12278:
-
[~tombentley] Haha, I was about to write something
[
https://issues.apache.org/jira/browse/KAFKA-12278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12278.
-
Resolution: Fixed
> Keep api versions consistent with api scope
>
junrao commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r578851481
##
File path:
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java
##
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r578850804
##
File path:
metadata/src/test/java/org/apache/kafka/controller/MockControllerMetrics.java
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r578850598
##
File path:
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java
##
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apache Software
jsancio commented on pull request #10138:
URL: https://github.com/apache/kafka/pull/10138#issuecomment-781734293
We got the following failures:
```
core:
ConfigCommandTest. shouldFailIfUnresolvableHost()
ConfigCommandTest. shouldFailIfUnresolvableHostUsingZookeeper()
[
https://issues.apache.org/jira/browse/KAFKA-12331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12331.
-
Resolution: Fixed
> KafkaRaftClient should use the LEO when appending
hachikuji merged pull request #10138:
URL: https://github.com/apache/kafka/pull/10138
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
jolshan edited a comment on pull request #10143:
URL: https://github.com/apache/kafka/pull/10143#issuecomment-781732199
Ran tests locally with newest code from trunk. Here are the tests that
failed:
```
ConsumerBounceTest.testClose()
jolshan edited a comment on pull request #10143:
URL: https://github.com/apache/kafka/pull/10143#issuecomment-781732199
Ran tests locally with newest code from trunk. Here are the tests that
failed:
```
ConsumerBounceTest.testClose()
jolshan commented on pull request #10143:
URL: https://github.com/apache/kafka/pull/10143#issuecomment-781732199
Ran tests locally with newest code from trunk. Here are the tests that
failed:
ConsumerBounceTest. testClose()
ConnectionQuotasTest.
jsancio commented on pull request #10138:
URL: https://github.com/apache/kafka/pull/10138#issuecomment-781730638
Ran the following commands locally:
```
$ ./gradlew -version
Gradle 6.8.1
cmccabe closed pull request #10066:
URL: https://github.com/apache/kafka/pull/10066
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
cmccabe commented on pull request #10066:
URL: https://github.com/apache/kafka/pull/10066#issuecomment-781727318
pushed
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
mjsax commented on pull request #10134:
URL: https://github.com/apache/kafka/pull/10134#issuecomment-781715946
Merged to `trunk` and cherry-picked to `2.8` branch.
This is an automated message from the Apache Git Service.
To
mjsax merged pull request #10134:
URL: https://github.com/apache/kafka/pull/10134
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
[
https://issues.apache.org/jira/browse/KAFKA-10192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286776#comment-17286776
]
Matthias J. Sax commented on KAFKA-10192:
-
Failed in setup:
[
https://issues.apache.org/jira/browse/KAFKA-10579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286774#comment-17286774
]
Matthias J. Sax commented on KAFKA-10579:
-
Different test method for same test:
[
https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12336:
Labels: easy-fix newbie (was: )
> custom stream naming does not work while calling
[
https://issues.apache.org/jira/browse/KAFKA-12336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12336:
Priority: Minor (was: Major)
> custom stream naming does not work while calling
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12328:
Summary: Expose TaskId partition number (was: Find out partition of a
store iterator)
>
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12328:
Labels: needs-kip (was: )
> Find out partition of a store iterator
>
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286771#comment-17286771
]
Matthias J. Sax commented on KAFKA-12328:
-
Personally, I am open to expose the partition number
cmccabe commented on a change in pull request #10066:
URL: https://github.com/apache/kafka/pull/10066#discussion_r578826004
##
File path: checkstyle/import-control.xml
##
@@ -99,6 +100,7 @@
+
Review comment:
Hmm. Let's revisit this after
cmccabe commented on a change in pull request #10066:
URL: https://github.com/apache/kafka/pull/10066#discussion_r578825895
##
File path: core/src/main/scala/kafka/server/ApiVersionManager.scala
##
@@ -0,0 +1,126 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
hachikuji commented on a change in pull request #10094:
URL: https://github.com/apache/kafka/pull/10094#discussion_r578823423
##
File path: bin/kafka-metadata-shell.sh
##
@@ -0,0 +1,17 @@
+#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+#
hachikuji commented on a change in pull request #10094:
URL: https://github.com/apache/kafka/pull/10094#discussion_r578818603
##
File path: bin/kafka-metadata-shell.sh
##
@@ -0,0 +1,17 @@
+#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one or more
+#
[
https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12344:
Affects Version/s: 2.7.0
> Support SlidingWindows in the Scala API
>
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r578817527
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java
##
@@ -0,0 +1,367 @@
+/*
+ * Licensed to the Apache
cmccabe commented on a change in pull request #10070:
URL: https://github.com/apache/kafka/pull/10070#discussion_r578817611
##
File path:
metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java
##
@@ -0,0 +1,597 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12344:
Labels: (was: streams)
> Support SlidingWindows in the Scala API
>
[
https://issues.apache.org/jira/browse/KAFKA-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12344:
Component/s: streams
> Support SlidingWindows in the Scala API
>
hachikuji commented on a change in pull request #10094:
URL: https://github.com/apache/kafka/pull/10094#discussion_r578813351
##
File path: metadata/src/main/java/org/apache/kafka/metalog/LocalLogManager.java
##
@@ -0,0 +1,378 @@
+/*
+ * Licensed to the Apache Software
rondagostino commented on pull request #10155:
URL: https://github.com/apache/kafka/pull/10155#issuecomment-781694442
Successfully ran `./gradlew build` after commenting out these two flaky
tests, **both of which passed locally when run individually afterwards**:
Leah Thomas created KAFKA-12344:
---
Summary: Support SlidingWindows in the Scala API
Key: KAFKA-12344
URL: https://issues.apache.org/jira/browse/KAFKA-12344
Project: Kafka
Issue Type:
abbccdda opened a new pull request #10156:
URL: https://github.com/apache/kafka/pull/10156
Add file-based store reloading mechanism, which does both file watch
triggering and time based reloading in a separate thread.
### Committer Checklist (excluded from commit message)
- [ ]
ijuma merged pull request #10146:
URL: https://github.com/apache/kafka/pull/10146
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
rondagostino commented on pull request #10146:
URL: https://github.com/apache/kafka/pull/10146#issuecomment-781651604
Successfully confirmed this fix locally as per comment in #10155.
This is an automated message from the
rondagostino commented on pull request #10155:
URL: https://github.com/apache/kafka/pull/10155#issuecomment-781650728
I successfully compiled locally. Compiling with `-PscalaVersion=2.12`
failed locally but then succeeded after applying the one-liner fix from
ijuma commented on pull request #10113:
URL: https://github.com/apache/kafka/pull/10113#issuecomment-781640866
@cmccabe Looks like the commit message is not as helpful as the PR
description. We typically copy the PR description to the commit message.
ijuma commented on pull request #10127:
URL: https://github.com/apache/kafka/pull/10127#issuecomment-781639872
The implementation that was removed was more efficient than the new
implementation. Is there a reason for that?
1 - 100 of 191 matches
Mail list logo
