abbccdda merged pull request #10017:
URL: https://github.com/apache/kafka/pull/10017
--
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.
For queries about this service, pleas
dajac commented on pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#issuecomment-848531545
@ijuma @lbradstreet Thanks for your review. Merging to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dajac merged pull request #10757:
URL: https://github.com/apache/kafka/pull/10757
--
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.
For queries about this service, please c
[
https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12243:
--
Assignee: loboxu
> Add toString methods to some of the classes introduced by this Epic
>
[
https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351587#comment-17351587
]
loboxu commented on KAFKA-12243:
[~jsancio] ,Is there a more detailed description of thi
chia7712 commented on a change in pull request #10761:
URL: https://github.com/apache/kafka/pull/10761#discussion_r639477851
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -325,19 +325,25 @@ class Log(@volatile private var _dir: File,
// Ensure we do not try t
Josep Prat created KAFKA-12850:
--
Summary: Use JDK16 for builds instead of JDK15
Key: KAFKA-12850
URL: https://issues.apache.org/jira/browse/KAFKA-12850
Project: Kafka
Issue Type: Improvement
mdedetrich commented on pull request #10762:
URL: https://github.com/apache/kafka/pull/10762#issuecomment-848553078
Okay PR is ready, some tests are failing but it seems to be due to unstable
CI
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351617#comment-17351617
]
Matthew de Detrich commented on KAFKA-12430:
I think I might just create a s
mdedetrich commented on pull request #10648:
URL: https://github.com/apache/kafka/pull/10648#issuecomment-848567812
As discussed in the mailing list, the other PR is more suitable since it
doesn't require a KIP, I will close this PR (it can be reopened later if
something else changes)
--
mdedetrich closed pull request #10648:
URL: https://github.com/apache/kafka/pull/10648
--
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.
For queries about this service, ple
cadonna opened a new pull request #10765:
URL: https://github.com/apache/kafka/pull/10765
As specified in KIP-743, this PR removes the built-in metrics
in Streams that are superseded by the refactoring proposed in KIP-444.
### Committer Checklist (excluded from commit message)
-
cadonna commented on pull request #10765:
URL: https://github.com/apache/kafka/pull/10765#issuecomment-848628471
Sorry for this massive cleanup PR: @guozhangwang @mjsax @ableegoldman
@vvcephei @abbccdda
--
This is an automated message from the Apache Git Service.
To respond to the me
showuon commented on a change in pull request #10765:
URL: https://github.com/apache/kafka/pull/10765#discussion_r639585452
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -175,11 +171,7 @@ public StreamsMe
cadonna commented on a change in pull request #10765:
URL: https://github.com/apache/kafka/pull/10765#discussion_r639602759
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -52,8 +51,7 @@
public class Strea
cadonna commented on pull request #10765:
URL: https://github.com/apache/kafka/pull/10765#issuecomment-848661315
>I did a search, and found there are still 2 places with related variables
that should be handled.
@showuon Nice catch!
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351691#comment-17351691
]
dc-heros commented on KAFKA-5892:
-
Hi [~jsahu], are you working on this? Can I take this
dengziming commented on pull request #10467:
URL: https://github.com/apache/kafka/pull/10467#issuecomment-848674442
Helli @dajac , are you interested in reviewing this PR, the current
`ListOffsets` implementation is very complex and can be simplified tremendously
if we use `AdminApiDriver`
jlprat opened a new pull request #10766:
URL: https://github.com/apache/kafka/pull/10766
Fixes the indentation of the code listings for:
* api.html
* configuration.html
* design.html
* implementation.html
* toc.html
These changes consist of whitespaces added or removed
jlprat commented on a change in pull request #10766:
URL: https://github.com/apache/kafka/pull/10766#discussion_r639680136
##
File path: docs/toc.html
##
@@ -86,26 +86,26 @@
Increasing replication factor
6.2 Datace
cadonna commented on a change in pull request #10428:
URL: https://github.com/apache/kafka/pull/10428#discussion_r639666899
##
File path: eclipse-formatter.xml
##
@@ -0,0 +1,60 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
jlprat opened a new pull request #10767:
URL: https://github.com/apache/kafka/pull/10767
Uses the right character for shell scripts (`>` instead of `$`)
Uses the right syntax highlighting
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementati
jlprat opened a new pull request #10768:
URL: https://github.com/apache/kafka/pull/10768
Fixes indentation, uses the right character for bash (`>`), and fixes
syntax highlighting for listings
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implemen
jlprat opened a new pull request #10769:
URL: https://github.com/apache/kafka/pull/10769
Uses the right tool to show code listings, so it is consistent with the
rest of the examples
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
jlprat opened a new pull request #10770:
URL: https://github.com/apache/kafka/pull/10770
Fix examples under security.html so they use the right bash icon (`>`
instead of `$`) and also uses the right tool for showing code listings
Some of the diffs are caused also by the IDE alignin
jlprat commented on pull request #10766:
URL: https://github.com/apache/kafka/pull/10766#issuecomment-848762136
CC. @cadonna as you reviewed the last doc changes on formatting and styling,
you might want to review these as well. I split the changes in several PRs so
it's more bearable to r
jlprat commented on pull request #10768:
URL: https://github.com/apache/kafka/pull/10768#issuecomment-848762557
CC. @cadonna as you reviewed the last doc changes on formatting and styling,
you might want to review these as well. I split the changes in several PRs so
it's more bearable to r
jlprat commented on pull request #10767:
URL: https://github.com/apache/kafka/pull/10767#issuecomment-848762425
CC. @cadonna as you reviewed the last doc changes on formatting and styling,
you might want to review these as well. I split the changes in several PRs so
it's more bearable to r
jlprat commented on pull request #10770:
URL: https://github.com/apache/kafka/pull/10770#issuecomment-848762769
CC. @cadonna as you reviewed the last doc changes on formatting and styling,
you might want to review these as well. I split the changes in several PRs so
it's more bearable to r
jlprat commented on pull request #10769:
URL: https://github.com/apache/kafka/pull/10769#issuecomment-848762697
CC. @cadonna as you reviewed the last doc changes on formatting and styling,
you might want to review these as well. I split the changes in several PRs so
it's more bearable to r
showuon commented on pull request #10338:
URL: https://github.com/apache/kafka/pull/10338#issuecomment-848770650
@mumrah , could you please take a look again? Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
KahnCheny commented on pull request #10746:
URL: https://github.com/apache/kafka/pull/10746#issuecomment-848777456
jenkins pr-merge passes?
--
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 sp
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351807#comment-17351807
]
jorge arada commented on KAFKA-7500:
Any ideia when the SinkConnector will be release
vvcephei commented on a change in pull request #10731:
URL: https://github.com/apache/kafka/pull/10731#discussion_r639778036
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
##
@@ -75,14 +75,20 @@
void init(final ProcessorC
jolshan commented on a change in pull request #10761:
URL: https://github.com/apache/kafka/pull/10761#discussion_r639833755
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -325,19 +325,25 @@ class Log(@volatile private var _dir: File,
// Ensure we do not try to
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351898#comment-17351898
]
Justine Olshan commented on KAFKA-12257:
With the changes from
[KIP-516|https:/
socutes closed pull request #10596:
URL: https://github.com/apache/kafka/pull/10596
--
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.
For queries about this service, please
socutes commented on pull request #10596:
URL: https://github.com/apache/kafka/pull/10596#issuecomment-848901314
PR is a little hasty, I submit each KIP to initiate the operation
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351898#comment-17351898
]
Justine Olshan edited comment on KAFKA-12257 at 5/26/21, 4:05 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351898#comment-17351898
]
Justine Olshan edited comment on KAFKA-12257 at 5/26/21, 4:05 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351898#comment-17351898
]
Justine Olshan edited comment on KAFKA-12257 at 5/26/21, 4:05 PM:
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12849:
---
Labels: needs-kip newbie newbie++ (was: )
> Consider migrating TaskMetadata
[
https://issues.apache.org/jira/browse/KAFKA-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351916#comment-17351916
]
Jitendra Sahu commented on KAFKA-5892:
--
Sure,go ahead.
> Connector property overrid
ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639896963
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java
##
@@ -40,6 +40,18 @@
private final Optional timeCur
cmccabe commented on a change in pull request #10752:
URL: https://github.com/apache/kafka/pull/10752#discussion_r639919437
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -246,9 +245,16 @@ class BrokerServer(
// Create transaction coordinator,
cmccabe commented on a change in pull request #10752:
URL: https://github.com/apache/kafka/pull/10752#discussion_r639919977
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -22,7 +22,6 @@ import java.util.concurrent.atomic.AtomicBoolean
import java.util.
cmccabe commented on a change in pull request #10752:
URL: https://github.com/apache/kafka/pull/10752#discussion_r639922279
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala
##
@@ -259,6 +260,10 @@ class BrokerMetadataListener(
clientQuo
cmccabe commented on pull request #10752:
URL: https://github.com/apache/kafka/pull/10752#issuecomment-848944712
Thanks for this, @mumrah . Very clean PR overall.
Can you add a test that the RPC fails if we don't have cluster
authorization, in `ControllerApisTest.scala`? Should be ve
cmccabe commented on a change in pull request #10752:
URL: https://github.com/apache/kafka/pull/10752#discussion_r639928477
##
File path:
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
##
@@ -1199,6 +1213,22 @@ public void processBatchEndOffset(long o
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351935#comment-17351935
]
Josep Prat commented on KAFKA-12849:
I would like to work on this one. Shall I first
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-12849:
---
Comment: was deleted
(was: I would like to work on this one. Shall I first create the KIP?)
> Consi
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351936#comment-17351936
]
Josep Prat commented on KAFKA-12849:
I would like to work on this one. Shall I creat
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat reassigned KAFKA-12849:
--
Assignee: Josep Prat
> Consider migrating TaskMetadata to interface with internal implementat
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351939#comment-17351939
]
Matthias J. Sax commented on KAFKA-12824:
-
It's not totally clear, but 4.0 shoul
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351940#comment-17351940
]
A. Sophie Blee-Goldman commented on KAFKA-12849:
Yep – it _should_ be re
ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639936420
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java
##
@@ -40,6 +40,18 @@
private final Optional timeCur
mumrah commented on a change in pull request #10752:
URL: https://github.com/apache/kafka/pull/10752#discussion_r639938409
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -22,7 +22,6 @@ import java.util.concurrent.atomic.AtomicBoolean
import java.util.c
mjsax commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639948650
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java
##
@@ -40,6 +40,18 @@
private final Optional timeCurrentIdl
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351946#comment-17351946
]
A. Sophie Blee-Goldman commented on KAFKA-9168:
---
Sounds good! This shouldn'
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351947#comment-17351947
]
Josep Prat commented on KAFKA-12849:
I'll prepare the KIP tomorrow
> Consider migra
[
https://issues.apache.org/jira/browse/KAFKA-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351948#comment-17351948
]
A. Sophie Blee-Goldman commented on KAFKA-12848:
[~sagarrao] John actual
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351965#comment-17351965
]
Josep Prat commented on KAFKA-12849:
Just to be sure, the intention is to convert Ta
ableegoldman commented on pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#issuecomment-848974085
Unrelated test failures:
`DynamicBrokerConfigTest.testPasswordConfigEncoderSecretChange()`
`RaftClusterTest`
`RaftEventSimulationTest.canMakeProgressIfMajorityIsReac
A. Sophie Blee-Goldman created KAFKA-12851:
--
Summary: Flaky Test
RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable
Key: KAFKA-12851
URL: https://issues.apache.org/jira/browse/KAFKA-12851
ableegoldman merged pull request #10755:
URL: https://github.com/apache/kafka/pull/10755
--
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.
For queries about this service, p
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351970#comment-17351970
]
A. Sophie Blee-Goldman commented on KAFKA-12849:
That's something we'll
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351974#comment-17351974
]
Josep Prat commented on KAFKA-12849:
Thanks a lot for the explanation! It's all clea
[
https://issues.apache.org/jira/browse/KAFKA-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351978#comment-17351978
]
Sagar Rao commented on KAFKA-12848:
---
[~ableegoldman], I think I have seen it in the AK
mjsax commented on a change in pull request #10731:
URL: https://github.com/apache/kafka/pull/10731#discussion_r640004045
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
##
@@ -75,14 +75,20 @@
void init(final ProcessorCont
tang7526 commented on a change in pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#discussion_r640016337
##
File path: core/src/main/scala/kafka/log/LogSegment.scala
##
@@ -162,15 +162,43 @@ class LogSegment private[log] (val log: FileRecords,
// appe
tang7526 commented on a change in pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#discussion_r640016337
##
File path: core/src/main/scala/kafka/log/LogSegment.scala
##
@@ -162,15 +162,43 @@ class LogSegment private[log] (val log: FileRecords,
// appe
tang7526 commented on pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#issuecomment-849014645
> @tang7526: Thanks for the PR. A few comments below. Also, could we add a
unit test for this?
Done.
--
This is an automated message from the Apache Git Service.
To re
tang7526 removed a comment on pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#issuecomment-825051965
@chia7712 Could you help to review this PR? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/KAFKA-9531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352010#comment-17352010
]
Britt Bolen commented on KAFKA-9531:
I see a similar issue using both the cli produce
[
https://issues.apache.org/jira/browse/KAFKA-9531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352010#comment-17352010
]
Britt Bolen edited comment on KAFKA-9531 at 5/26/21, 6:27 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352010#comment-17352010
]
Britt Bolen edited comment on KAFKA-9531 at 5/26/21, 6:28 PM:
-
tang7526 commented on a change in pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#discussion_r640024597
##
File path: core/src/main/scala/kafka/log/LogSegment.scala
##
@@ -162,15 +162,43 @@ class LogSegment private[log] (val log: FileRecords,
// appe
tang7526 commented on a change in pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#discussion_r640027627
##
File path: core/src/main/scala/kafka/log/LogSegment.scala
##
@@ -162,15 +162,43 @@ class LogSegment private[log] (val log: FileRecords,
// appe
tang7526 commented on a change in pull request #10534:
URL: https://github.com/apache/kafka/pull/10534#discussion_r640027627
##
File path: core/src/main/scala/kafka/log/LogSegment.scala
##
@@ -162,15 +162,43 @@ class LogSegment private[log] (val log: FileRecords,
// appe
mumrah commented on a change in pull request #10752:
URL: https://github.com/apache/kafka/pull/10752#discussion_r640070688
##
File path:
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java
##
@@ -1199,6 +1213,22 @@ public void processBatchEndOffset(long of
kowshik commented on pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#issuecomment-849086875
Thanks for the review @junrao! I have addressed your comments in
4b836034415c3d5f6b84384ef9be1e75b66edc4b.
--
This is an automated message from the Apache Git Service.
To resp
junrao merged pull request #10756:
URL: https://github.com/apache/kafka/pull/10756
--
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.
For queries about this service, please
Jun Rao created KAFKA-12852:
---
Summary: Log.splitOverflowedSegment() doesn't generate producer
snapshot for new segment
Key: KAFKA-12852
URL: https://issues.apache.org/jira/browse/KAFKA-12852
Project: Kafka
mjsax commented on a change in pull request #10668:
URL: https://github.com/apache/kafka/pull/10668#discussion_r640126531
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -491,25 +493,23 @@ public void testStateThreadClose() throws Except
mjsax commented on a change in pull request #10668:
URL: https://github.com/apache/kafka/pull/10668#discussion_r640127195
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -525,14 +525,13 @@ public void testStateGlobalThreadClose() throws
Colin McCabe created KAFKA-12853:
Summary: Implement broker-side KRaft snapshots
Key: KAFKA-12853
URL: https://issues.apache.org/jira/browse/KAFKA-12853
Project: Kafka
Issue Type: Improvement
Lincong Li created KAFKA-12854:
--
Summary: Add a config to allow skipping metadata cache update when
topic partition is unassigned
Key: KAFKA-12854
URL: https://issues.apache.org/jira/browse/KAFKA-12854
P
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12550:
--
Assignee: (was: A. Sophie Blee-Goldman)
> Introduce RESTORING sta
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12550:
---
Priority: Major (was: Blocker)
> Introduce RESTORING state to the KafkaStre
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12550:
---
Fix Version/s: (was: 3.0.0)
4.0.0
> Introduce RESTORI
lbradstreet commented on pull request #10704:
URL: https://github.com/apache/kafka/pull/10704#issuecomment-849144204
@ijuma I figured out the cause with some state change checks. The problem is
that we're passing a recording map through to the channel/principal builders,
and the recording
ableegoldman commented on pull request #10657:
URL: https://github.com/apache/kafka/pull/10657#issuecomment-849145231
Hey @vitojeng , was this the final PR for KIP-216? If not is the next one
available yet? No rush, just want to make sure you haven't been waiting on
reviews this whole time
lbradstreet edited a comment on pull request #10704:
URL: https://github.com/apache/kafka/pull/10704#issuecomment-849144204
@ijuma I figured out the cause with some state change checks. The problem is
that we're passing a recording map through to the channel/principal builders,
and the rec
[
https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-5876:
--
Description:
Currently, IQ does only throws {{InvalidStateStoreException}} for
ableegoldman edited a comment on pull request #10657:
URL: https://github.com/apache/kafka/pull/10657#issuecomment-849145231
Hey @vitojeng , was this the final PR for KIP-216? If not is the next one
available yet? No rush, just want to make sure you haven't been waiting on
reviews this who
[
https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352111#comment-17352111
]
Pedro Gontijo commented on KAFKA-12845:
---
Thanks for the reply [~mjsax]
I see what
[
https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352111#comment-17352111
]
Pedro Gontijo edited comment on KAFKA-12845 at 5/26/21, 10:43 PM:
prince-mahajan opened a new pull request #10771:
URL: https://github.com/apache/kafka/pull/10771
Fixing the link to a cited blog. The existing link now points to a steroid
website so need to pull the blog from internet archives.
*More detailed description of your change,
if necess
vitojeng commented on pull request #10657:
URL: https://github.com/apache/kafka/pull/10657#issuecomment-849170302
@ableegoldman Thanks for your concern, KIP-216 still in progress. 🙂
It's really busy in the last two weeks, some bad things continue to happen
in Taiwan.
I will stick to
ijuma commented on a change in pull request #10704:
URL: https://github.com/apache/kafka/pull/10704#discussion_r640186978
##
File path:
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java
##
@@ -106,7 +107,7 @@ public AbstractConfig(ConfigDef definition, M
1 - 100 of 123 matches
Mail list logo
