[
https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew Sheppard updated KAFKA-13289:
-
Description:
When pushing bulk data through a kafka-steams app, I see it log the followi
chia7712 commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r705913852
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -977,6 +977,11 @@ private StreamThread createAndAddStreamThread(fina
dajac merged pull request #11318:
URL: https://github.com/apache/kafka/pull/11318
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
dajac commented on pull request #11318:
URL: https://github.com/apache/kafka/pull/11318#issuecomment-916669933
@omkreddy Yes, we should also fix trunk. I will do a separate one for it.
--
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-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew Sheppard updated KAFKA-13289:
-
Summary: Bulk processing correctly ordered input data through a join with
kafka-streams
[
https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew Sheppard updated KAFKA-13289:
-
Description:
When pushing bulk data through a kafka-steams app, I see it log the followi
[
https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew Sheppard updated KAFKA-13289:
-
Description:
When pushing bulk data through a kafka-steams app, I see it log the followi
Matthew Sheppard created KAFKA-13289:
Summary: Bulk processing data through a join with kafka-streams
results in `Skipping record for expired segment`
Key: KAFKA-13289
URL: https://issues.apache.org/jira/brows
omkreddy commented on a change in pull request #11318:
URL: https://github.com/apache/kafka/pull/11318#discussion_r705926622
##
File path: docs/upgrade.html
##
@@ -39,7 +39,7 @@ Notable changes in 2
-Upgrading to 2.7.0 from any
version 0.8.x through 2.6.x
+Upgrading
omkreddy commented on a change in pull request #11318:
URL: https://github.com/apache/kafka/pull/11318#discussion_r705926622
##
File path: docs/upgrade.html
##
@@ -39,7 +39,7 @@ Notable changes in 2
-Upgrading to 2.7.0 from any
version 0.8.x through 2.6.x
+Upgrading
dajac opened a new pull request #11318:
URL: https://github.com/apache/kafka/pull/11318
### 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-13287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-13287:
--
Assignee: Bruno Cadonna
> Upgrade RocksDB to 6.22.1.1
> -
[
https://issues.apache.org/jira/browse/KAFKA-13216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-13216:
---
Assignee: Guozhang Wang
> Streams left/outer joins cause new internal changelog top
mjsax closed pull request #11235:
URL: https://github.com/apache/kafka/pull/11235
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
mjsax commented on pull request #11235:
URL: https://github.com/apache/kafka/pull/11235#issuecomment-916630468
Closing the PR in favor of #11252.
The performance of this PR is really bad, while #11252 shows stable
performance.
--
This is an automated message from the Apache Git Se
mjsax commented on a change in pull request #11252:
URL: https://github.com/apache/kafka/pull/11252#discussion_r705883780
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -280,85 +279,51 @@ private void assertUniqueStore
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412950#comment-17412950
]
Matthias J. Sax commented on KAFKA-13256:
-
Thanks. Just wondering if this PR fix
ijuma commented on pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#issuecomment-916526936
@chia7712 Conflicts are resolved. :)
--
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 t
Jason Gustafson created KAFKA-13288:
---
Summary: Transaction find-hanging command with --broker-id
excludes internal topics
Key: KAFKA-13288
URL: https://issues.apache.org/jira/browse/KAFKA-13288
Proj
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r705721987
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -658,23 +676,28 @@ private[log] class Cleaner(val id: Int,
}
}
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r705721022
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -163,17 +168,18 @@ private[log] class LogCleanerManager(val logDirs:
Seq[Fi
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r705721022
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -163,17 +168,18 @@ private[log] class LogCleanerManager(val logDirs:
Seq[Fi
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hao Li reassigned KAFKA-13164:
--
Assignee: Hao Li
> State store is attached to wrong node in the Kafka Streams topology
>
cadonna opened a new pull request #11317:
URL: https://github.com/apache/kafka/pull/11317
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgra
[
https://issues.apache.org/jira/browse/KAFKA-13287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13287:
--
Fix Version/s: 3.1.0
> Upgrade RocksDB to 6.22.1.1
> ---
>
>
Bruno Cadonna created KAFKA-13287:
-
Summary: Upgrade RocksDB to 6.22.1.1
Key: KAFKA-13287
URL: https://issues.apache.org/jira/browse/KAFKA-13287
Project: Kafka
Issue Type: Task
Comp
[
https://issues.apache.org/jira/browse/KAFKA-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13286:
--
Description:
Kafka Streams state store is built in hierarchical layers as metered -> cached
-
Guozhang Wang created KAFKA-13286:
-
Summary: Revisit Streams State Store and Serde Implementation
Key: KAFKA-13286
URL: https://issues.apache.org/jira/browse/KAFKA-13286
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once i
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once i
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once i
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once i
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once i
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
F Méthot updated KAFKA-13272:
-
Description:
Our KStream app offset stay stuck on 1 partition after outage possibly when
exactly_once i
[
https://issues.apache.org/jira/browse/KAFKA-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412714#comment-17412714
]
Jun Rao commented on KAFKA-8334:
[~geek-chen]: This is a server side issue. So you will n
junrao commented on pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#issuecomment-916281257
@satishd : Could you rebase this PR? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/KAFKA-12988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-12988.
-
Fix Version/s: 3.1.0
Resolution: Fixed
merged the PR to trunk.
> Change RLMM add/updateRemoteLog
junrao merged pull request #11033:
URL: https://github.com/apache/kafka/pull/11033
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr..
jeqo opened a new pull request #11316:
URL: https://github.com/apache/kafka/pull/11316
As part of the migration of KStream/KTable operations to the new Processor
API https://issues.apache.org/jira/browse/KAFKA-8410, this PR includes the
migration of KTable aggregate/reduce operations.
[
https://issues.apache.org/jira/browse/KAFKA-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya resolved KAFKA-10542.
--
Resolution: Fixed
https://github.com/apache/kafka/pull/11099
[
https://issues.apache.org/jira/browse/KAFKA-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya resolved KAFKA-13201.
--
Resolution: Fixed
https://github.com/apache/kafka/pull/11213
[
https://issues.apache.org/jira/browse/KAFKA-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya reassigned KAFKA-13201:
Assignee: Jorge Esteban Quilcate Otoya
> Convert KTable s
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-13256:
--
Assignee: René Kerner
> Possible NPE in ConfigDef when rendering (enriched) RST or HT
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13256:
---
Affects Version/s: 3.0.0
> Possible NPE in ConfigDef when rendering (enriched) RST or HTML w
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-13256.
Fix Version/s: 3.1.0
Resolution: Fixed
> Possible NPE in ConfigDef when rendering (
mimaison merged pull request #11287:
URL: https://github.com/apache/kafka/pull/11287
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr
jeqo opened a new pull request #11315:
URL: https://github.com/apache/kafka/pull/11315
As part of the migration of KStream/KTable operations to the new Processor
API https://issues.apache.org/jira/browse/KAFKA-8410, this PR includes the
migration of KStream aggregate/reduce operations.
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412670#comment-17412670
]
Maatari edited comment on KAFKA-10643 at 9/9/21, 4:18 PM:
--
So j
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412670#comment-17412670
]
Maatari commented on KAFKA-10643:
-
So just you know, we tried, and it has an effect,
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412623#comment-17412623
]
Maatari edited comment on KAFKA-10643 at 9/9/21, 2:49 PM:
--
[~gr
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412623#comment-17412623
]
Maatari edited comment on KAFKA-10643 at 9/9/21, 2:48 PM:
--
[~gr
wcarlson5 commented on pull request #11278:
URL: https://github.com/apache/kafka/pull/11278#issuecomment-916170147
@guozhangwang I think there are defiantly questions to be answered about
this and really what we want to the user to achieve. I think the
maxbufferedbytes is really being use
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412623#comment-17412623
]
Maatari commented on KAFKA-10643:
-
[~gray.john] It feels like disabling it altogether mi
dajac merged pull request #11314:
URL: https://github.com/apache/kafka/pull/11314
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...
Tom Bentley created KAFKA-13285:
---
Summary: Use consistent access modifier for Admin clients Result
classes
Key: KAFKA-13285
URL: https://issues.apache.org/jira/browse/KAFKA-13285
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412602#comment-17412602
]
John Gray commented on KAFKA-10643:
---
[~maatdeamon] hey your understanding appears abou
mimaison commented on a change in pull request #10983:
URL: https://github.com/apache/kafka/pull/10983#discussion_r705288892
##
File path: docs/ops.html
##
@@ -845,6 +845,11 @@ https://github.com/apache/kafka/blob/trunk/connect/mirror-client/src/main/java/org/apache/kafka/conne
patrickstuedi commented on a change in pull request #10798:
URL: https://github.com/apache/kafka/pull/10798#discussion_r705268638
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java
##
@@ -32,34 +34,49 @@
private final by
rk3rn3r commented on a change in pull request #11287:
URL: https://github.com/apache/kafka/pull/11287#discussion_r705252513
##
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##
@@ -1372,11 +1372,13 @@ public String toEnrichedRst() {
*/
rk3rn3r commented on a change in pull request #11287:
URL: https://github.com/apache/kafka/pull/11287#discussion_r705251404
##
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##
@@ -1372,11 +1372,13 @@ public String toEnrichedRst() {
*/
[
https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412498#comment-17412498
]
Maatari commented on KAFKA-10643:
-
[~gray.john] I do have state store to restore, it is
mimaison commented on a change in pull request #11287:
URL: https://github.com/apache/kafka/pull/11287#discussion_r705140109
##
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##
@@ -1372,11 +1372,13 @@ public String toEnrichedRst() {
*/
tombentley commented on a change in pull request #11301:
URL: https://github.com/apache/kafka/pull/11301#discussion_r705112124
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -3178,7 +3178,8 @@ public DescribeConsumerGroupsResult
mimaison commented on pull request #10649:
URL: https://github.com/apache/kafka/pull/10649#issuecomment-915876743
@rajinisivaram Thanks for the reviews. I hope we have answered your
comments. Do you have any more questions?
--
This is an automated message from the Apache Git Service.
To
64 matches
Mail list logo