[
https://issues.apache.org/jira/browse/KAFKA-10411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjay Ravikumar updated KAFKA-10411:
-
Description:
There is an extra line break in the streams processor API documentation in
[
https://issues.apache.org/jira/browse/KAFKA-10411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjay Ravikumar updated KAFKA-10411:
-
Description:
There is an extra line break in the streams processor API documentation in
[
https://issues.apache.org/jira/browse/KAFKA-10411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179405#comment-17179405
]
Sanjay Ravikumar commented on KAFKA-10411:
--
I would like to take this up as I'm
Sanjay Ravikumar created KAFKA-10411:
Summary: Extra line break in streams processor API documentation
Key: KAFKA-10411
URL: https://issues.apache.org/jira/browse/KAFKA-10411
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Yurchenko reassigned KAFKA-9726:
-
Assignee: Ivan Yurchenko (was: Ryanne Dolan)
> LegacyReplicationPolicy for MM2 to mimic
kkonstantine commented on pull request #9176:
URL: https://github.com/apache/kafka/pull/9176#issuecomment-675264751
Thanks @carlos-verdes
I'll try to take a look within the next couple of weeks (taking some time
off in the meantime).
Without commenting on the approach yet, I'm p
[
https://issues.apache.org/jira/browse/KAFKA-10406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjay Ravikumar reassigned KAFKA-10406:
Assignee: (was: Sanjay Ravikumar)
> Table data doesn't wrap around in fixed-w
[
https://issues.apache.org/jira/browse/KAFKA-10406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjay Ravikumar reassigned KAFKA-10406:
Assignee: Sanjay Ravikumar
> Table data doesn't wrap around in fixed-width column
omkreddy edited a comment on pull request #9192:
URL: https://github.com/apache/kafka/pull/9192#issuecomment-675202022
Merged to trunk and all the branches upto 1.0.
This is an automated message from the Apache Git Service.
T
omkreddy commented on pull request #9192:
URL: https://github.com/apache/kafka/pull/9192#issuecomment-675202022
Merged to trunk, 2.6, 2.5, 2.4 branches.
This is an automated message from the Apache Git Service.
To respond to
omkreddy closed pull request #9192:
URL: https://github.com/apache/kafka/pull/9192
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
cmccabe opened a new pull request #9194:
URL: https://github.com/apache/kafka/pull/9194
For the generated message code, put the JSON conversion functionality
in a separate JsonConverter class.
Make MessageDataGenerator simply another generator class, alongside the
new JsonConver
dielhennr commented on a change in pull request #9101:
URL: https://github.com/apache/kafka/pull/9101#discussion_r466653159
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -504,6 +515,7 @@ public void onSuccess(Byt
ableegoldman commented on a change in pull request #9137:
URL: https://github.com/apache/kafka/pull/9137#discussion_r471836789
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java
##
@@ -188,7 +188,55 @@ public void testPu
[
https://issues.apache.org/jira/browse/KAFKA-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10409:
Component/s: streams
> Refactor Kafka Streams RocksDb iterators
> ---
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r471798256
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -0,0 +1,301 @@
+/*
+ * License
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r471806378
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -977,14 +1179,30 @@ class KafkaController(val config: KafkaConfig,
/**
soarez commented on pull request #9064:
URL: https://github.com/apache/kafka/pull/9064#issuecomment-675135083
Ping @mjsax - a reminder to review this
This is an automated message from the Apache Git Service.
To respond to th
soarez commented on pull request #9000:
URL: https://github.com/apache/kafka/pull/9000#issuecomment-675134899
Pinging @mjsax. Don't forget to review this.
This is an automated message from the Apache Git Service.
To respond t
[
https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179220#comment-17179220
]
Ryanne Dolan commented on KAFKA-10370:
--
Thanks [~yangguo1220]. I believe that using
Mark Shelton created KAFKA-10410:
Summary: OnRestoreStart disappeared from StateRestoreCallback in
2.6.0 and reappeared in a useless place
Key: KAFKA-10410
URL: https://issues.apache.org/jira/browse/KAFKA-10410
chrisbeard opened a new pull request #9193:
URL: https://github.com/apache/kafka/pull/9193
This is a starting point for the implementation of the tool proposed in
[KIP-640](https://cwiki.apache.org/confluence/display/KAFKA/KIP-640%3A+Add+log+compression+analysis+tool).
I consider thi
andrewegel opened a new pull request #9192:
URL: https://github.com/apache/kafka/pull/9192
- bcrypt (a dependency of ducktape) dropped Python2.7 support.
ducktape-0.7.9 now pins bcrypt to a Python2.7-supported version.
*More detailed description of your change,
if necessary. The
[
https://issues.apache.org/jira/browse/KAFKA-10406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179178#comment-17179178
]
Sanjay Ravikumar commented on KAFKA-10406:
--
[~ableegoldman] yes, that's the cor
ableegoldman commented on a change in pull request #9191:
URL: https://github.com/apache/kafka/pull/9191#discussion_r471696179
##
File path:
streams/src/main/java/org/apache/kafka/streams/errors/MissingSourceTopicException.java
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brian Byrne resolved KAFKA-10158.
-
Resolution: Fixed
> Fix flaky
> kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderRe
[
https://issues.apache.org/jira/browse/KAFKA-10406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179154#comment-17179154
]
Sophie Blee-Goldman commented on KAFKA-10406:
-
I think the link in the ticke
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r471627837
##
File path: clients/src/main/resources/common/message/UpdateFeaturesRequest.json
##
@@ -0,0 +1,33 @@
+// Licensed to the Apache Software Foundation (ASF) u
[
https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179133#comment-17179133
]
Ryanne Dolan commented on KAFKA-9726:
-
[~ivanyu] that'd be great!
> LegacyReplicatio
vvcephei commented on a change in pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#discussion_r471582580
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -415,9 +416,40 @@ public final Sens
cwildman commented on pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#issuecomment-674974228
Noticed this didn't make the 2.6 release. Would it be possible to backport
this to older 2.x versions? Or is 2.6.1 coming soon? Dealing with some
environments with bad settings f
cadonna commented on pull request #9177:
URL: https://github.com/apache/kafka/pull/9177#issuecomment-674954410
JDK 8 and Scala 1.12 had following test failures:
```
org.apache.kafka.connect.runtime.WorkerSourceTaskWithTopicCreationTest.testCommitFailure
kafka.api.Plaint
astubbs edited a comment on pull request #9031:
URL: https://github.com/apache/kafka/pull/9031#issuecomment-674942888
Jira: https://issues.apache.org/jira/browse/KAFKA-10298
KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-645%3A+Replace+Windows+with+a+proper+interface
--
astubbs commented on pull request #9031:
URL: https://github.com/apache/kafka/pull/9031#issuecomment-674942888
Jira: https://issues.apache.org/jira/browse/KAFKA-10298
This is an automated message from the Apache Git Service.
cadonna commented on pull request #9191:
URL: https://github.com/apache/kafka/pull/9191#issuecomment-674933287
FYI: @guozhangwang @ableegoldman @vvcephei @mjsax @abbccdda
This is an automated message from the Apache Git Serv
cadonna opened a new pull request #9191:
URL: https://github.com/apache/kafka/pull/9191
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade not
[
https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179034#comment-17179034
]
John Roesler commented on KAFKA-10408:
--
Thanks for the report [~astubbs] . Note: th
vvcephei closed pull request #9074:
URL: https://github.com/apache/kafka/pull/9074
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
dongjinleekr commented on pull request #9189:
URL: https://github.com/apache/kafka/pull/9189#issuecomment-674898490
@huxihx
> Besides, deliveryTimeoutMs is added by #5425 without any KIP covered.
Great! It perfectly makes sense.
--
[
https://issues.apache.org/jira/browse/KAFKA-10023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-10023.
Fix Version/s: 2.7.0
Reviewer: Rajini Sivaram
Resolution: Fixed
> Enforce
rajinisivaram merged pull request #8768:
URL: https://github.com/apache/kafka/pull/8768
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
rajinisivaram commented on pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#issuecomment-674884255
@apovzner Thanks for the updates, LGTM. Merging to trunk.
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178966#comment-17178966
]
Ivan Yurchenko commented on KAFKA-9726:
---
[~ryannedolan], if you're not working on t
jeqo commented on a change in pull request #9137:
URL: https://github.com/apache/kafka/pull/9137#discussion_r471459574
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java
##
@@ -188,7 +188,55 @@ public void testPutGetRang
[
https://issues.apache.org/jira/browse/KAFKA-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-10409:
-
Description:
>From [https://github.com/apache/kafka/pull/9137#di
Jorge Esteban Quilcate Otoya created KAFKA-10409:
Summary: Refactor Kafka Streams RocksDb iterators
Key: KAFKA-10409
URL: https://issues.apache.org/jira/browse/KAFKA-10409
Project: Kaf
jeqo commented on a change in pull request #9137:
URL: https://github.com/apache/kafka/pull/9137#discussion_r471451498
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java
##
@@ -374,7 +412,7 @@ public Bytes peekNextKey() {
jeqo commented on a change in pull request #9137:
URL: https://github.com/apache/kafka/pull/9137#discussion_r471449807
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java
##
@@ -374,7 +412,7 @@ public Bytes peekNextKey() {
[
https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Antony Stubbs updated KAFKA-10408:
--
Description:
A date based window, for example aggregate all payments made until each month
da
huxihx commented on pull request #9189:
URL: https://github.com/apache/kafka/pull/9189#issuecomment-674828127
@dongjinleekr Thanks for the comments. I think it needs no KIP for this
patch, since it does not break any compatibility. It's totally okay for you not
to specify them when using K
[
https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-10408:
-
Assignee: (was: Bruno Cadonna)
> Calendar based windows
> --
>
Antony Stubbs created KAFKA-10408:
-
Summary: Calendar based windows
Key: KAFKA-10408
URL: https://issues.apache.org/jira/browse/KAFKA-10408
Project: Kafka
Issue Type: New Feature
Co
dongjinleekr commented on pull request #9189:
URL: https://github.com/apache/kafka/pull/9189#issuecomment-674807281
Hi @huxihx,
It seems like this feature requires a KIP. Isn't it?
This is an automated message from the
[
https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178519#comment-17178519
]
Vagesh Mathapati edited comment on KAFKA-10396 at 8/17/20, 9:36 AM:
--
rajinisivaram commented on pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#issuecomment-674769912
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log o
rajinisivaram commented on pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#issuecomment-674768235
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, plea
rajinisivaram commented on pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#issuecomment-674767765
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log o
jwijgerd closed pull request #9190:
URL: https://github.com/apache/kafka/pull/9190
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
jwijgerd opened a new pull request #9190:
URL: https://github.com/apache/kafka/pull/9190
*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
59 matches
Mail list logo
