[
https://issues.apache.org/jira/browse/KAFKA-4279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186268#comment-17186268
]
Rupesh Kumar Patel commented on KAFKA-4279:
---
Hi Gwen,
I am pretty new to Kafka community, can
[
https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186265#comment-17186265
]
Matthias J. Sax commented on KAFKA-10366:
-
Following [~ableegoldman] last comment on the discuss
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r478774195
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java
##
@@ -419,13 +504,13 @@ Long minTime() {
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r478770009
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java
##
@@ -416,26 +552,43 @@ private long
ableegoldman commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r478769493
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java
##
@@ -287,17 +308,43 @@ public void
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478769004
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,386 @@
+/*
+ *
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478768625
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,386 @@
+/*
+ *
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478768335
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,386 @@
+/*
+ *
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478766196
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -232,40 +239,54 @@ private
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478763071
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -189,8 +195,8 @@ public void
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478762667
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -174,12 +181,11 @@ public
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478762151
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,386 @@
+/*
+ *
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478761540
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,380 @@
+/*
+ *
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478759996
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478759996
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478758779
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478758482
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478756346
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,303 @@
+/*
+ *
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478753568
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,303 @@
+/*
+ * Licensed to
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478751787
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,303 @@
+/*
+ *
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478751787
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,303 @@
+/*
+ *
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478744162
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public void
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478743528
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public void
vvcephei commented on pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#issuecomment-682235389
Hey @cadonna , after checking out your branch and merging with trunk, I
discovered some minor conflicts with 22bcd9fac3c988c15862d0b6c01930814b676253,
so I pushed a quick fix
vvcephei merged pull request #9177:
URL: https://github.com/apache/kafka/pull/9177
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
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478730796
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,303 @@
+/*
+ * Licensed to
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478730765
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478730258
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478730258
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478728829
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,303 @@
+/*
+ * Licensed to
lct45 commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478726427
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,303 @@
+/*
+ * Licensed to
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478717127
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
##
@@ -0,0 +1,466 @@
+/*
+ *
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478716769
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,391 @@
+/*
+ *
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478715664
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,391 @@
+/*
+ *
vvcephei commented on pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#issuecomment-682208742
Since the PR builds aren't running, I'm merging with trunk on my machine and
running the tests.
This is an
vvcephei commented on a change in pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#discussion_r478709525
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -396,34 +398,65 @@ private String
vvcephei commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r478588602
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java
##
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-10410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186092#comment-17186092
]
Mark Shelton commented on KAFKA-10410:
--
Yes using a Singleton would work, like I said in my first
cmccabe commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r478657275
##
File path: core/src/test/scala/unit/kafka/utils/JaasTestUtils.scala
##
@@ -169,6 +169,18 @@ object JaasTestUtils {
jaasFile
}
+ // Returns a
cmccabe commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r478656313
##
File path: tests/kafkatest/version.py
##
@@ -63,8 +63,13 @@ def
reassign_partitions_command_supports_bootstrap_server(self):
return self >=
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r478653535
##
File path: tests/kafkatest/services/security/security_config.py
##
@@ -350,6 +362,14 @@ def kafka_opts(self):
else:
return ""
Ron Dagostino created KAFKA-10443:
-
Summary: Consider providing standard set of users in system tests
Key: KAFKA-10443
URL: https://issues.apache.org/jira/browse/KAFKA-10443
Project: Kafka
cmccabe commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r478652254
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -575,10 +577,21 @@ def set_unclean_leader_election(self, topic, value=True,
node=None):
cmccabe commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r478652254
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -575,10 +577,21 @@ def set_unclean_leader_election(self, topic, value=True,
node=None):
cmccabe commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r478646950
##
File path: tests/kafkatest/services/security/security_config.py
##
@@ -350,6 +362,14 @@ def kafka_opts(self):
else:
return ""
+
cmccabe commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r478646271
##
File path: tests/kafkatest/services/security/security_config.py
##
@@ -276,18 +287,19 @@ def setup_node(self, node):
if java_version(node) <=
avocader opened a new pull request #9227:
URL: https://github.com/apache/kafka/pull/9227
The `org.apache.kafka.connect.data.Values#parse` method parses integers,
which are larger than `Long.MAX_VALUE` as `double` with `Schema.FLOAT64_SCHEMA`.
That means we are losing precision for
ijuma commented on a change in pull request #9129:
URL: https://github.com/apache/kafka/pull/9129#discussion_r478640519
##
File path: jmh-benchmarks/README.md
##
@@ -34,7 +34,18 @@ the jmh.sh script from the jmh-benchmarks module.
* By default all JMH output goes to stdout.
ijuma commented on a change in pull request #9129:
URL: https://github.com/apache/kafka/pull/9129#discussion_r478639981
##
File path: jmh-benchmarks/README.md
##
@@ -34,7 +34,18 @@ the jmh.sh script from the jmh-benchmarks module.
* By default all JMH output goes to stdout.
ijuma commented on a change in pull request #9129:
URL: https://github.com/apache/kafka/pull/9129#discussion_r478639377
##
File path: README.md
##
@@ -199,6 +199,27 @@ You can run spotbugs using:
The spotbugs warnings will be found in `reports/spotbugs/main.html` and
lbradstreet commented on a change in pull request #9129:
URL: https://github.com/apache/kafka/pull/9129#discussion_r478637097
##
File path: README.md
##
@@ -199,6 +199,27 @@ You can run spotbugs using:
The spotbugs warnings will be found in `reports/spotbugs/main.html` and
lbradstreet commented on a change in pull request #9129:
URL: https://github.com/apache/kafka/pull/9129#discussion_r478636719
##
File path: jmh-benchmarks/README.md
##
@@ -34,7 +34,18 @@ the jmh.sh script from the jmh-benchmarks module.
* By default all JMH output goes to
lbradstreet commented on a change in pull request #9129:
URL: https://github.com/apache/kafka/pull/9129#discussion_r478635770
##
File path: jmh-benchmarks/README.md
##
@@ -34,7 +34,18 @@ the jmh.sh script from the jmh-benchmarks module.
* By default all JMH output goes to
guozhangwang commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r478608933
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -411,7 +411,10 @@ boolean
guozhangwang commented on pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#issuecomment-68204
> Is this planned for a follow-up PR or were you just waiting to get a
review of the basics before diving deeper into this work?
Yes that's the plan. More concreted
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r478604292
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -100,7 +100,8 @@ case class LogAppendInfo(var firstOffset: Option[Long],
guozhangwang commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r478605835
##
File path:
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java
##
@@ -123,7 +123,7 @@ public void
mumrah opened a new pull request #9226:
URL: https://github.com/apache/kafka/pull/9226
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-10410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186019#comment-17186019
]
Guozhang Wang commented on KAFKA-10410:
---
Thanks Mark for your explanation. I think for metrics
vvcephei commented on a change in pull request #9222:
URL: https://github.com/apache/kafka/pull/9222#discussion_r478586348
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/StateStoreContext.java
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache
ning2008wisc commented on pull request #9215:
URL: https://github.com/apache/kafka/pull/9215#issuecomment-682090080
@mimaison thanks for your review. Regarding to your general comment about
moving MM2 Readme to the Kafka documentation, I think it is a good idea to
promote MM2 in the
ning2008wisc commented on a change in pull request #9215:
URL: https://github.com/apache/kafka/pull/9215#discussion_r478583076
##
File path: connect/mirror/README.md
##
@@ -141,7 +141,38 @@ nearby clusters.
N.B. that the `--clusters` parameter is not technically required
[
https://issues.apache.org/jira/browse/KAFKA-10442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-10442:
---
Assignee: Jason Gustafson
> Tooling to detect and abort hanging transactions
Jason Gustafson created KAFKA-10442:
---
Summary: Tooling to detect and abort hanging transactions (KIP-664)
Key: KAFKA-10442
URL: https://issues.apache.org/jira/browse/KAFKA-10442
Project: Kafka
brbrown25 commented on pull request #9057:
URL: https://github.com/apache/kafka/pull/9057#issuecomment-682058178
@mimaison Thank You, I'll review and submit a KIP this afternoon!
This is an automated message from the Apache
mimaison commented on pull request #8798:
URL: https://github.com/apache/kafka/pull/8798#issuecomment-682051575
Ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-10272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-10272:
--
Assignee: Jesse Gorzinski
> kafka-server-stop.sh fails on IBM i
>
mimaison commented on pull request #9023:
URL: https://github.com/apache/kafka/pull/9023#issuecomment-682027790
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 #9177:
URL: https://github.com/apache/kafka/pull/9177#discussion_r478504532
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -396,34 +398,65 @@ private String
mimaison commented on pull request #9057:
URL: https://github.com/apache/kafka/pull/9057#issuecomment-682013531
Thanks for the contribution.
As this is adding new public classes, this change requires a KIP:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals
[
https://issues.apache.org/jira/browse/KAFKA-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185907#comment-17185907
]
Pradyumna edited comment on KAFKA-10441 at 8/27/20, 3:12 PM:
-
Do we need to
[
https://issues.apache.org/jira/browse/KAFKA-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185907#comment-17185907
]
Pradyumna commented on KAFKA-10441:
---
Do we need to copy the
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478490860
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -232,40 +239,54 @@ private void
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478489438
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -232,40 +239,54 @@ private void
mimaison commented on pull request #9122:
URL: https://github.com/apache/kafka/pull/9122#issuecomment-682006762
Ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185897#comment-17185897
]
Pradyumna edited comment on KAFKA-10441 at 8/27/20, 2:56 PM:
-
Interestingly,
[
https://issues.apache.org/jira/browse/KAFKA-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185897#comment-17185897
]
Pradyumna commented on KAFKA-10441:
---
Interestingly, the MBean is available for these metrics, and it
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185890#comment-17185890
]
Goltseva Taisiia edited comment on KAFKA-7421 at 8/27/20, 2:43 PM:
---
Hi,
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185890#comment-17185890
]
Goltseva Taisiia edited comment on KAFKA-7421 at 8/27/20, 2:42 PM:
---
Hi,
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185891#comment-17185891
]
Goltseva Taisiia commented on KAFKA-7421:
-
And I agree with [~ivanyu], I do not understand why
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185891#comment-17185891
]
Goltseva Taisiia edited comment on KAFKA-7421 at 8/27/20, 2:38 PM:
---
And
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185890#comment-17185890
]
Goltseva Taisiia commented on KAFKA-7421:
-
Hi, guys!
We faced the similar deadlock (not equal
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478462394
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -232,40 +239,54 @@ private void
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478459405
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -189,8 +195,8 @@ public void
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478454716
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,380 @@
+/*
+ * Licensed to
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478445137
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public void
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478442739
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -174,12 +181,11 @@ public void
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478437596
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,380 @@
+/*
+ * Licensed to
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r478435832
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -160,11 +160,18 @@ public void
mimaison commented on a change in pull request #9215:
URL: https://github.com/apache/kafka/pull/9215#discussion_r478425022
##
File path: connect/mirror/README.md
##
@@ -141,7 +141,38 @@ nearby clusters.
N.B. that the `--clusters` parameter is not technically required here.
Pradyumna created KAFKA-10441:
-
Summary: Connect consumers are missing the fetch metrics
Key: KAFKA-10441
URL: https://issues.apache.org/jira/browse/KAFKA-10441
Project: Kafka
Issue Type: Bug
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r478349804
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java
##
@@ -287,17 +308,43 @@ public void
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r478340031
##
File path: streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
##
@@ -119,15 +118,16 @@
*
* This iterator must be closed
xakassi commented on a change in pull request #9211:
URL: https://github.com/apache/kafka/pull/9211#discussion_r478325832
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java
##
@@ -733,10 +734,11 @@ public void
xakassi commented on a change in pull request #9211:
URL: https://github.com/apache/kafka/pull/9211#discussion_r478325832
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java
##
@@ -733,10 +734,11 @@ public void
kkonstantine commented on pull request #9211:
URL: https://github.com/apache/kafka/pull/9211#issuecomment-681830490
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log
kkonstantine commented on a change in pull request #9211:
URL: https://github.com/apache/kafka/pull/9211#discussion_r478275661
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java
##
@@ -733,10 +734,11 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nandini Anagondi updated KAFKA-10440:
-
Description:
I found an issue while running MM2 using Kconnect Framework. Based on the
huxihx commented on pull request #9225:
URL: https://github.com/apache/kafka/pull/9225#issuecomment-681778195
@ijuma Please review this patch. Thanks.
This is an automated message from the Apache Git Service.
To respond to
huxihx opened a new pull request #9225:
URL: https://github.com/apache/kafka/pull/9225
https://issues.apache.org/jira/browse/KAFKA-10431
Currently, ProducerPerformance randomly selects a payload from the payload
file when sending message. This might cause the some payloads being
1 - 100 of 117 matches
Mail list logo