fvaleri commented on code in PR #13048:
URL: https://github.com/apache/kafka/pull/13048#discussion_r1058184040
##
storage/src/test/java/org/apache/kafka/server/log/remote/storage/ClassLoaderAwareRemoteStorageManagerTest.java:
##
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/KAFKA-14554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri updated KAFKA-14554:
Fix Version/s: 3.5.0
> Move ClassLoaderAwareRemoteStorageManagerTest to storage module
> -
showuon opened a new pull request, #13050:
URL: https://github.com/apache/kafka/pull/13050
In KRaft, when controller failed to handle events, we'll log error and
return back to brokers. But in some cases, we only log error class name, and
return error class name back to brokers, which is un
showuon commented on PR #13050:
URL: https://github.com/apache/kafka/pull/13050#issuecomment-1366523644
@jsancio @dengziming , call for review
--
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
mimaison commented on code in PR #13038:
URL: https://github.com/apache/kafka/pull/13038#discussion_r1058234223
##
storage/src/main/java/org/apache/kafka/server/log/internals/LogOffsetMetadata.java:
##
@@ -0,0 +1,103 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
[
https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Yurchenko reassigned KAFKA-8206:
-
Assignee: Ivan Yurchenko
> A consumer can't discover new group coordinator when the clus
ijuma commented on code in PR #13048:
URL: https://github.com/apache/kafka/pull/13048#discussion_r1058393160
##
storage/src/test/java/org/apache/kafka/server/log/remote/storage/ClassLoaderAwareRemoteStorageManagerTest.java:
##
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Soft
ijuma merged PR #13048:
URL: https://github.com/apache/kafka/pull/13048
--
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...@kafka.apache.or
ashmeet13 commented on PR #12988:
URL: https://github.com/apache/kafka/pull/12988#issuecomment-1366703839
Hi @ableegoldman thank you for the review!
I went through the producer configs and was not able to find any config with
the name `default.partitioner`. Were you referring to the `part
ijuma opened a new pull request, #13051:
URL: https://github.com/apache/kafka/pull/13051
The former may fail or return misleading results if the properties don't
include defaults.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [
[
https://issues.apache.org/jira/browse/KAFKA-14554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri resolved KAFKA-14554.
-
Resolution: Fixed
> Move ClassLoaderAwareRemoteStorageManagerTest to storage module
> --
[
https://issues.apache.org/jira/browse/KAFKA-14552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14552:
Description:
Kafka 4.0 will remove support for zk mode and kraft mode became production
ready in
[
https://issues.apache.org/jira/browse/KAFKA-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-13748:
-
Assignee: Chris Egerton (was: Konstantine Karantasis)
> Do not include file stream con
ijuma commented on PR #13051:
URL: https://github.com/apache/kafka/pull/13051#issuecomment-1366843677
@jsancio Yes, right - this preempts a potential issue if KRaft starts using
some of the other properties. This fix also means we don't need to add a
workaround in the PR that moves LogConfi
ijuma commented on PR #13051:
URL: https://github.com/apache/kafka/pull/13051#issuecomment-1366844162
JDK 17 build passed, the other failures are unrelated:
> Build / JDK 11 and Scala 2.13 /
kafka.server.DynamicBrokerReconfigurationTest.testTrustStoreAlter(String).quorum=kraft
> Bu
ijuma merged PR #13051:
URL: https://github.com/apache/kafka/pull/13051
--
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...@kafka.apache.or
mjsax merged PR #12166:
URL: https://github.com/apache/kafka/pull/12166
--
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...@kafka.apache.or
mjsax commented on PR #12166:
URL: https://github.com/apache/kafka/pull/12166#issuecomment-1366902096
Thanks for the PR! Merged to `trunk`.
--
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 spe
mjsax closed pull request #12999: [REVERT] Kip-837
URL: https://github.com/apache/kafka/pull/12999
--
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-
ijuma commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1058580168
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -544,7 +544,7 @@ case class MetadataLogConfig(logSegmentBytes: Int,
retentio
mjsax merged PR #12613:
URL: https://github.com/apache/kafka/pull/12613
--
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...@kafka.apache.or
mjsax commented on PR #12613:
URL: https://github.com/apache/kafka/pull/12613#issuecomment-1366909926
Thanks for the PR. Merged to `trunk`.
--
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 spe
mjsax commented on PR #12608:
URL: https://github.com/apache/kafka/pull/12608#issuecomment-1366911487
Can you create a JIRA ticket for this PR? If it's not working right now, I
would consider it a bug.
And yes, I agree that merging a KStream with itself should result in
duplicating e
mjsax commented on code in PR #12608:
URL: https://github.com/apache/kafka/pull/12608#discussion_r1058585746
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java:
##
@@ -1694,6 +1694,28 @@ public void shouldMergeMultipleStreams() {
mjsax commented on code in PR #12608:
URL: https://github.com/apache/kafka/pull/12608#discussion_r1058586441
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPassThrough.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mjsax commented on PR #12895:
URL: https://github.com/apache/kafka/pull/12895#issuecomment-1366920157
Cherry-picked to `3.4` branch.
--
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 c
mjsax commented on PR #12937:
URL: https://github.com/apache/kafka/pull/12937#issuecomment-1366920260
Cherry-picked to `3.4` branch.
--
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 c
[
https://issues.apache.org/jira/browse/KAFKA-13881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13881.
-
Fix Version/s: 3.4.0
(was: 3.5.0)
Resolution: Fixed
> Add
ijuma commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1058599006
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -1211,50 +1184,50 @@ object KafkaConfig {
.define(NumPartitionsProp, INT, Defaults.NumPartitions, atLe
mjsax commented on PR #12154:
URL: https://github.com/apache/kafka/pull/12154#issuecomment-1366925372
We can remove deprecated APIs only after keeping them for at least one year,
plus only in a major release. Cannot merge this PR. Closing it for now -- feel
free to re-open when we announce
mjsax closed pull request #12154: KAFKA-12828 Remove deprecated methods in
KeyQueryMetadata
URL: https://github.com/apache/kafka/pull/12154
--
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 specif
ijuma commented on PR #13049:
URL: https://github.com/apache/kafka/pull/13049#issuecomment-1366926066
JDK 8 and JDK 11 builds passed, JDK 17 had one unrelated failure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
mjsax merged PR #11049:
URL: https://github.com/apache/kafka/pull/11049
--
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...@kafka.apache.or
mjsax commented on PR #11049:
URL: https://github.com/apache/kafka/pull/11049#issuecomment-1366930598
Thanks for the PR!
--
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
jlprat commented on PR #11049:
URL: https://github.com/apache/kafka/pull/11049#issuecomment-1366931538
Thank you for reviewing and merging!
--
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 spe
ijuma commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1058615668
##
storage/src/main/java/org/apache/kafka/server/log/internals/LogConfig.java:
##
@@ -0,0 +1,504 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
mjsax commented on code in PR #11047:
URL: https://github.com/apache/kafka/pull/11047#discussion_r1058616311
##
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java:
##
@@ -143,17 +143,6 @@ public void shouldThrowNullPointerIfInnerIsNull() {
mjsax commented on PR #10373:
URL: https://github.com/apache/kafka/pull/10373#issuecomment-1366934397
@andygarfield Thanks for the PR -- seems there are merge conflict. Could you
rebase the PR so we can merge it?
--
This is an automated message from the Apache Git Service.
To respond to t
ijuma commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1058623037
##
storage/src/main/java/org/apache/kafka/server/log/internals/LogConfig.java:
##
@@ -0,0 +1,504 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
ijuma commented on code in PR #13049:
URL: https://github.com/apache/kafka/pull/13049#discussion_r1058623369
##
storage/src/main/java/org/apache/kafka/server/log/internals/LogConfig.java:
##
@@ -0,0 +1,504 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
mjsax commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1366950411
@maseiler -- thanks for your PR -- could you update it so we can merge it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
mjsax closed pull request #7330: KAFKA-8894: Bump streams test topic deletion
assertion timeout from 30s to 60s
URL: https://github.com/apache/kafka/pull/7330
--
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
mjsax commented on PR #7330:
URL: https://github.com/apache/kafka/pull/7330#issuecomment-1366953638
Closing this PR as the corresponding Jira ticket is marked "resolved".
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
mjsax commented on PR #9972:
URL: https://github.com/apache/kafka/pull/9972#issuecomment-1366954511
> KAFKA-8779: Reintroduce flaky tests
@tombentley -- I don't think we should re-introduce flaky tests 😁 (sorry,
not sorry; couldn't resist)
--
This is an automated message from the A
mjsax commented on PR #7034:
URL: https://github.com/apache/kafka/pull/7034#issuecomment-1366955141
@eneveu -- Thanks for the PR. Seems it's outdated. Would you like to update
it so we can merge it?
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
mjsax commented on PR #6640:
URL: https://github.com/apache/kafka/pull/6640#issuecomment-1366956240
@sekikn -- Thanks for the PR -- could you rebase it so we can merge it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
mjsax closed pull request #6512: Add KStream branch with fluent API
URL: https://github.com/apache/kafka/pull/6512
--
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 unsubscrib
mjsax commented on PR #6512:
URL: https://github.com/apache/kafka/pull/6512#issuecomment-1366957170
This PR proposed a public API change, and thus we need to do a KIP first:
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals
Closing this PR for now. We can r
mjsax merged PR #8335:
URL: https://github.com/apache/kafka/pull/8335
--
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...@kafka.apache.org
mjsax commented on PR #8335:
URL: https://github.com/apache/kafka/pull/8335#issuecomment-1366968297
Thanks for the PR @vkorenev -- merge to `trunk` (better late than never...)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/KAFKA-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652611#comment-17652611
]
Matthias J. Sax commented on KAFKA-8403:
[~vvcephei] – given https://issues.apach
mjsax commented on PR #6856:
URL: https://github.com/apache/kafka/pull/6856#issuecomment-1366969603
The corresponding Jira is resolved. Closing this PR.
--
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
mjsax closed pull request #6856: KAFKA-8410: [POC] strong typing for processors
URL: https://github.com/apache/kafka/pull/6856
--
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.
T
mjsax merged PR #11569:
URL: https://github.com/apache/kafka/pull/11569
--
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...@kafka.apache.or
mjsax commented on PR #11569:
URL: https://github.com/apache/kafka/pull/11569#issuecomment-1366969914
Thanks for the PR. Merged to `trunk`.
--
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 spe
mjsax merged PR #12008:
URL: https://github.com/apache/kafka/pull/12008
--
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...@kafka.apache.or
mjsax commented on PR #12008:
URL: https://github.com/apache/kafka/pull/12008#issuecomment-1366971324
Thanks for the PR! Merged to `trunk`.
--
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 spe
csolidum opened a new pull request, #13052:
URL: https://github.com/apache/kafka/pull/13052
Now returns an empty Optional instead of throwing a NullPointerException
Added a new test case to cover passing in a null offsetAndMetadata to make
sure the works as expected.
### Commit
[
https://issues.apache.org/jira/browse/KAFKA-14545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652612#comment-17652612
]
Chris Solidum commented on KAFKA-14545:
---
ended up making the change in checkpoint
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652613#comment-17652613
]
Matthias J. Sax commented on KAFKA-10493:
-
Given that "version KTable" KIP is ap
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10493.
-
Fix Version/s: (was: 4.0.0)
Assignee: (was: Matthias J. Sax)
Reso
mjsax commented on PR #12356:
URL: https://github.com/apache/kafka/pull/12356#issuecomment-1366975287
Given that we have
https://cwiki.apache.org/confluence/display/KAFKA/KIP-889%3A+Versioned+State+Stores
approved, I close the corresponding Jira (and the other open PR for it:
https://githu
mjsax closed pull request #12356: KAFKA-10493: Drop out-of-order records in
KTable
URL: https://github.com/apache/kafka/pull/12356
--
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 commen
mjsax commented on PR #10533:
URL: https://github.com/apache/kafka/pull/10533#issuecomment-1366975494
Given that we have
https://cwiki.apache.org/confluence/display/KAFKA/KIP-889%3A+Versioned+State+Stores
approved, I close the corresponding Jira (and the other open PR for it:
https://githu
mjsax closed pull request #10533: KAFKA-10493: Drop out-of-order KTable records
(WIP)
URL: https://github.com/apache/kafka/pull/10533
--
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 com
mjsax merged PR #12431:
URL: https://github.com/apache/kafka/pull/12431
--
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...@kafka.apache.or
gharris1727 opened a new pull request, #13053:
URL: https://github.com/apache/kafka/pull/13053
This module exposes a single package as public API that needs a package
description.
Similar to #12895.
Signed-off-by: Greg Harris
### Committer Checklist (excluded from commi
gharris1727 commented on PR #13053:
URL: https://github.com/apache/kafka/pull/13053#issuecomment-1366977403
@mimaison Sorry for the delay on opening this, I didn't notice this package
was public API.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
mjsax commented on code in PR #12608:
URL: https://github.com/apache/kafka/pull/12608#discussion_r1058650295
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java:
##
@@ -532,29 +532,36 @@ private KStream merge(final InternalStreamsBuilder
builder
mjsax commented on code in PR #12608:
URL: https://github.com/apache/kafka/pull/12608#discussion_r1058650447
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java:
##
@@ -1694,6 +1694,28 @@ public void shouldMergeMultipleStreams() {
mjsax merged PR #12470:
URL: https://github.com/apache/kafka/pull/12470
--
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...@kafka.apache.or
mjsax commented on PR #12470:
URL: https://github.com/apache/kafka/pull/12470#issuecomment-1366983200
Thanks for the PR. Merged to `trunk` and cherry-picked to `3.4` branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652620#comment-17652620
]
Matthias J. Sax commented on KAFKA-13295:
-
[~ableegoldman] – I am wondering if t
mjsax commented on PR #11977:
URL: https://github.com/apache/kafka/pull/11977#issuecomment-1366985040
@nico-javadev -- you never followed up on the PR comment. Are you still
interested to work on this?
--
This is an automated message from the Apache Git Service.
To respond to the message,
mjsax commented on PR #9328:
URL: https://github.com/apache/kafka/pull/9328#issuecomment-1366985275
@mumrah -- do you still want to get this done? Or should we close this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
mjsax merged PR #10164:
URL: https://github.com/apache/kafka/pull/10164
--
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...@kafka.apache.or
mjsax commented on PR #10164:
URL: https://github.com/apache/kafka/pull/10164#issuecomment-1366985697
Thanks for the PR. Merged to `trunk`.
--
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 spe
mjsax commented on code in PR #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r1058656046
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java:
##
@@ -45,34 +45,30 @@ public void setIfUnset(final Serializer
defaultKeySeri
mjsax merged PR #6867:
URL: https://github.com/apache/kafka/pull/6867
--
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...@kafka.apache.org
mjsax commented on PR #6867:
URL: https://github.com/apache/kafka/pull/6867#issuecomment-1366991182
Thanks for the PR. Merged to `trunk` and cherry-picked to `3.4` branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
mjsax closed pull request #6851: MINOR: Check for needed commits inside
numIterations loop to avoid txn timeouts
URL: https://github.com/apache/kafka/pull/6851
--
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
mjsax commented on PR #6851:
URL: https://github.com/apache/kafka/pull/6851#issuecomment-1366991898
Closing this PR as outdated. We did fix a few things with regard to
committing and transaction timeout in the mean time anyway.
--
This is an automated message from the Apache Git Service.
mjsax commented on PR #6530:
URL: https://github.com/apache/kafka/pull/6530#issuecomment-1366992418
Closing this PR and re-open it to retrigger a test run.
--
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
mjsax closed pull request #6530: add break keyword, when globalGroups has
already updated.
URL: https://github.com/apache/kafka/pull/6530
--
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
mjsax commented on PR #6530:
URL: https://github.com/apache/kafka/pull/6530#issuecomment-1366992569
Seems, cannot re-open.
--
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.
T
mjsax commented on PR #10569:
URL: https://github.com/apache/kafka/pull/10569#issuecomment-1366993106
Closing this PR due to inactivity. We never received a KIP proposal that
would be required for a public API change.
--
This is an automated message from the Apache Git Service.
To respond
mjsax closed pull request #10569: KAFKA-12696: Adds standardized getters to
LagInfo class
URL: https://github.com/apache/kafka/pull/10569
--
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
mjsax commented on PR #1668:
URL: https://github.com/apache/kafka/pull/1668#issuecomment-1366994295
Closing this old PR -- the corresponding Jira is marked as "resolved".
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
mjsax closed pull request #1668: KAFKA-3973: feasibility caching bytes vs
records
URL: https://github.com/apache/kafka/pull/1668
--
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.
mjsax closed pull request #2159: KAFKA-4273 - Add TTL support for RocksDB
URL: https://github.com/apache/kafka/pull/2159
--
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 unsu
mjsax commented on PR #2159:
URL: https://github.com/apache/kafka/pull/2159#issuecomment-1366994483
Closing this stale PR due to inactivity. We would need a KIP for this change
to begin with.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
mjsax closed pull request #3134: KAFKA-5315: should not subtract for empty key
in KTable.aggregate/reduce
URL: https://github.com/apache/kafka/pull/3134
--
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
mjsax commented on PR #3581:
URL: https://github.com/apache/kafka/pull/3581#issuecomment-1366995064
Closing this stale PR due to inactivity. We would need an approved KIP
anyway before we could merge it.
--
This is an automated message from the Apache Git Service.
To respond to the messag
mjsax closed pull request #3581: KAFKA-5648: make Merger extend Aggregator
URL: https://github.com/apache/kafka/pull/3581
--
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 uns
mjsax commented on PR #3657:
URL: https://github.com/apache/kafka/pull/3657#issuecomment-1366995270
Closing this old PR due to inactivity. PR would need to be rebased anyway.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
mjsax closed pull request #3657: Kafka-5676: MockStreamsMetrics should be in
o.a.k.test
URL: https://github.com/apache/kafka/pull/3657
--
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 co
mjsax closed pull request #4453: KAFKA-6035: Avoid creating changelog topics
for state stores that are directly piped to a sink topic
URL: https://github.com/apache/kafka/pull/4453
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
mjsax commented on PR #4453:
URL: https://github.com/apache/kafka/pull/4453#issuecomment-1366995849
Closing this stale PR due to inactivity. We still want this improvement, but
the PR would need to be updated to the latest code base.
--
This is an automated message from the Apache Git Ser
mjsax commented on PR #4680:
URL: https://github.com/apache/kafka/pull/4680#issuecomment-1366996267
Closing this stale PR due to inactivity. Not even sure if we would still
need this refactoring given all the changes we applied in the mean time.
--
This is an automated message from the Ap
mjsax closed pull request #4680: Feature/refactor subscription info
URL: https://github.com/apache/kafka/pull/4680
--
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 unsubscrib
1 - 100 of 145 matches
Mail list logo
