[
https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12796:
Labels: scala (was: )
> Removal of deprecated classes under `streams-scala`
> ---
hudeqi opened a new pull request #10716:
URL: https://github.com/apache/kafka/pull/10716
1. besides `latest` and `earliest`, we also add `nearest`: reset to either
latest or earliest depending on the current offset (i.e. this policy won't
trigger under the scenario when we see a partition
showuon commented on pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#issuecomment-842947967
Broken tests are fixed and new tests are added for multiple generation tests
for unequal subscription cases. Thanks.
--
This is an automated message from the Apache Git Servic
Nicolas Guyomar created KAFKA-12805:
---
Summary: Aborted send could have a different exception than
DisconnectException
Key: KAFKA-12805
URL: https://issues.apache.org/jira/browse/KAFKA-12805
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-12751.
Reviewer: David Arthur
Resolution: Fixed
> ISRs remain in in-flight state if propose
[
https://issues.apache.org/jira/browse/KAFKA-12805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Guyomar updated KAFKA-12805:
Description:
Right now we are treating timeout in the network client as a disconnection
e
jlprat commented on pull request #10711:
URL: https://github.com/apache/kafka/pull/10711#issuecomment-842993232
cc @ijuma Could you please review this PR, as you were one the last ones to
do a similar change?
Thanks in advance
--
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346805#comment-17346805
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
[~guozhang] I am keen to get such a featu
[
https://issues.apache.org/jira/browse/KAFKA-12801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346835#comment-17346835
]
Gunnar Morling commented on KAFKA-12801:
Would a JFR profiling work, too? I coul
Gunnar Morling created KAFKA-12806:
--
Summary: KRaft: Confusing leadership status exposed for controller
without quorum
Key: KAFKA-12806
URL: https://issues.apache.org/jira/browse/KAFKA-12806
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gunnar Morling updated KAFKA-12806:
---
Description:
I'm testing Kafka in the new KRaft mode added in 2.8. I have a cluster of three
[
https://issues.apache.org/jira/browse/KAFKA-12806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gunnar Morling updated KAFKA-12806:
---
Summary: KRaft: Confusing leadership status exposed in metrics for
controller without quorum
NLincoln opened a new pull request #10717:
URL: https://github.com/apache/kafka/pull/10717
See #10709 for an example of this happening.
The tl;dr is that Jackson will ignore trailing tokens by default, but other
Json parsers cannot be configured to ignore them. This makes sure we don
Naresh created KAFKA-12807:
--
Summary: allow mTLS authorization based on different fields of
X509 certificate
Key: KAFKA-12807
URL: https://issues.apache.org/jira/browse/KAFKA-12807
Project: Kafka
I
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-843148293
@hachikuji I fixed the tests and made you suggested changes, but what do you
think about @guozhangwang's point
[above](https://github.com/apache/kafka/pull/9441#discussion_r624
Josep Prat created KAFKA-12808:
--
Summary: Remove Deprecated methods under StreamsMetricsImpl
Key: KAFKA-12808
URL: https://issues.apache.org/jira/browse/KAFKA-12808
Project: Kafka
Issue Type: Ta
[
https://issues.apache.org/jira/browse/KAFKA-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat reassigned KAFKA-12808:
--
Assignee: Josep Prat
> Remove Deprecated methods under StreamsMetricsImpl
> -
[
https://issues.apache.org/jira/browse/KAFKA-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346891#comment-17346891
]
Josep Prat commented on KAFKA-12808:
I'll take this one
> Remove Deprecated methods
Josep Prat created KAFKA-12809:
--
Summary: Remove De
Key: KAFKA-12809
URL: https://issues.apache.org/jira/browse/KAFKA-12809
Project: Kafka
Issue Type: Task
Reporter: Josep Prat
[
https://issues.apache.org/jira/browse/KAFKA-12809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-12809:
---
Component/s: streams
Fix Version/s: 3.0.0
Description:
There are 2 methods in org.apache
[
https://issues.apache.org/jira/browse/KAFKA-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-12808:
---
Summary: Remove Deprecated methods under StreamsMetrics (was: Remove
Deprecated methods under Strea
[
https://issues.apache.org/jira/browse/KAFKA-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-12808:
---
Description:
There are 4 methods in StreamMetrics and StreamsMetricsImpl that are deprecated
since
Josep Prat created KAFKA-12810:
--
Summary: Remove deprecated TopologyDescription.Source#topics
Key: KAFKA-12810
URL: https://issues.apache.org/jira/browse/KAFKA-12810
Project: Kafka
Issue Type: S
[
https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-12419:
---
Description:
Here's a list of deprecated APIs that we have accumulated in the past, we can
consider
[
https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346902#comment-17346902
]
Josep Prat commented on KAFKA-12419:
I created https://issues.apache.org/jira/browse
showuon commented on pull request #10457:
URL: https://github.com/apache/kafka/pull/10457#issuecomment-843191316
failed tests are unrelated and flaky. Thanks.
```
Build / JDK 15 and Scala 2.13 /
org.apache.kafka.connect.integration.BlockingConnectorTest.testBlockInSinkTaskStart
mumrah merged pull request #10561:
URL: https://github.com/apache/kafka/pull/10561
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346920#comment-17346920
]
Lucas Bradstreet commented on KAFKA-12801:
--
JFR is perfectly fine too.
> High
cadonna commented on a change in pull request #10651:
URL: https://github.com/apache/kafka/pull/10651#discussion_r634203662
##
File path: docs/streams/developer-guide/app-reset-tool.html
##
@@ -78,18 +78,17 @@
Step 1: Run the application reset tool
Inv
jlprat commented on pull request #10651:
URL: https://github.com/apache/kafka/pull/10651#issuecomment-843207783
Thanks @cadonna, all good points. I'll address the feedback later
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Richard Joerger created KAFKA-12811:
---
Summary: kafka-topics.sh should let the user know they cannot
adjust the replication factor for a topic using the --alter flag and not warn
about missing the --partition flag
Key: KAFKA-128
rondagostino commented on pull request #10550:
URL: https://github.com/apache/kafka/pull/10550#issuecomment-843228313
@cmccabe I merged in trunk and pushed a separate commit to fix the failing
unit tests. The way we test to ensure an API is always forwarded for KRaft is
to send the reques
[
https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346969#comment-17346969
]
Matthew de Detrich commented on KAFKA-9726:
---
Would it be possible to assign the
Moovlin opened a new pull request #10718:
URL: https://github.com/apache/kafka/pull/10718
Added 1 new line to check that that "replication factor" & "alter" are not
being used together. Uses the existing CommandLineUtils to do the check.
Committer Checklist (excluded from commit mess
[
https://issues.apache.org/jira/browse/KAFKA-12811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346980#comment-17346980
]
Richard Joerger commented on KAFKA-12811:
-
Hi team, I've gone ahead and submitte
jlprat commented on a change in pull request #10651:
URL: https://github.com/apache/kafka/pull/10651#discussion_r634513734
##
File path: docs/streams/developer-guide/app-reset-tool.html
##
@@ -78,18 +78,17 @@
Step 1: Run the application reset tool
Invo
satishd commented on pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#issuecomment-843289802
@junrao @kowshik This PR is ready for review. Pl let me know your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew de Detrich reassigned KAFKA-9726:
-
Assignee: Matthew de Detrich (was: Ivan Yurchenko)
> LegacyReplicationPolicy fo
Guozhang Wang created KAFKA-12812:
-
Summary: Consider refactoring state store registration path
Key: KAFKA-12812
URL: https://issues.apache.org/jira/browse/KAFKA-12812
Project: Kafka
Issue Ty
soarez commented on pull request #10650:
URL: https://github.com/apache/kafka/pull/10650#issuecomment-843352974
@ijuma can you have a look at this one?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347051#comment-17347051
]
Guozhang Wang commented on KAFKA-12812:
---
The reason I feel this is better is that,
mumrah commented on a change in pull request #10504:
URL: https://github.com/apache/kafka/pull/10504#discussion_r634580042
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -2376,6 +2375,82 @@ class KafkaController(val config: KafkaConfig,
}
soarez closed pull request #10195:
URL: https://github.com/apache/kafka/pull/10195
--
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
soarez commented on pull request #10195:
URL: https://github.com/apache/kafka/pull/10195#issuecomment-843357496
This was fixed by #10203
--
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 speci
ijuma commented on pull request #10650:
URL: https://github.com/apache/kafka/pull/10650#issuecomment-843373430
@soarez the concern is that it may hide a problem. So, it's important to
understand the sequence of events.
--
This is an automated message from the Apache Git Service.
To respo
soarez commented on pull request #10650:
URL: https://github.com/apache/kafka/pull/10650#issuecomment-843367411
Hi @dhruvilshah3
This happened when a broker that was offline for a long time came back up. I
agree this shouldn't happen in the first place. I have logs, but it isn't clea
guozhangwang commented on a change in pull request #10609:
URL: https://github.com/apache/kafka/pull/10609#discussion_r634626047
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -411,19 +442,37 @@ private void cleanRemo
mumrah merged pull request #10431:
URL: https://github.com/apache/kafka/pull/10431
--
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
ableegoldman commented on pull request #10713:
URL: https://github.com/apache/kafka/pull/10713#issuecomment-843513828
Some flaky test failures, Java11 build passed and this is a trivial renaming
anyways. Merging
--
This is an automated message from the Apache Git Service.
To respond to t
ableegoldman merged pull request #10713:
URL: https://github.com/apache/kafka/pull/10713
--
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
mimaison commented on pull request #10660:
URL: https://github.com/apache/kafka/pull/10660#issuecomment-843514462
@mjsax / @chia7712 Can you take another look? Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
ableegoldman commented on pull request #10715:
URL: https://github.com/apache/kafka/pull/10715#issuecomment-843543131
@showuon I don't think we need to increase the heartbeat interval, let's
just bump up the session timeout for now. We still want to be relatively quick
in our broker reques
[
https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347153#comment-17347153
]
A. Sophie Blee-Goldman commented on KAFKA-12812:
100% agree. Imo the old
ableegoldman commented on a change in pull request #10646:
URL: https://github.com/apache/kafka/pull/10646#discussion_r634736745
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -174,13 +176,15 @@ public void re
mumrah opened a new pull request #10719:
URL: https://github.com/apache/kafka/pull/10719
Fixes for two compiler errors which were introduced in
https://github.com/apache/kafka/pull/10431
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
junrao commented on a change in pull request #10719:
URL: https://github.com/apache/kafka/pull/10719#discussion_r634743071
##
File path:
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java
##
@@ -63,7 +63,7 @@ public void close() {
String.f
jsancio commented on pull request #10719:
URL: https://github.com/apache/kafka/pull/10719#issuecomment-843561287
LGTM. Compiles locally and `KafkaMetadataLogTest` passes locally. Thanks
@mumrah
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
jsancio commented on a change in pull request #10719:
URL: https://github.com/apache/kafka/pull/10719#discussion_r634746833
##
File path:
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java
##
@@ -63,7 +63,7 @@ public void close() {
String.
mumrah merged pull request #10719:
URL: https://github.com/apache/kafka/pull/10719
--
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
[
https://issues.apache.org/jira/browse/KAFKA-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming resolved KAFKA-10195.
Resolution: Won't Fix
> Move offset management codes from ConsumerCoordinator to a new class
> ---
ryannedolan commented on pull request #10681:
URL: https://github.com/apache/kafka/pull/10681#issuecomment-843668847
Failing tests seem unrelated (KRaft and Streams).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
showuon commented on pull request #10715:
URL: https://github.com/apache/kafka/pull/10715#issuecomment-843681372
@ableegoldman , no problem! Updated! 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 abo
mjsax opened a new pull request #10720:
URL: https://github.com/apache/kafka/pull/10720
When getting a value from an upstream state store, we should ensure that the
record timestamp is accessible when applying a `Transformer`.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346805#comment-17346805
]
NEERAJ VAIDYA edited comment on KAFKA-12776 at 5/19/21, 1:45 AM:
-
mjsax commented on a change in pull request #10720:
URL: https://github.com/apache/kafka/pull/10720#discussion_r634858161
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java
##
@@ -63,15 +63,14 @@ public void enableSendingOldVal
mjsax commented on a change in pull request #10720:
URL: https://github.com/apache/kafka/pull/10720#discussion_r634859119
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java
##
@@ -141,16 +144,32 @@ public void close() {
[
https://issues.apache.org/jira/browse/KAFKA-12811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347257#comment-17347257
]
Luke Chen commented on KAFKA-12811:
---
[~rjoerger], I've helped you move this ticket int
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347259#comment-17347259
]
A. Sophie Blee-Goldman commented on KAFKA-12776:
[~neeraj.vaidya] althou
ViE-17-tuoi opened a new pull request #10721:
URL: https://github.com/apache/kafka/pull/10721
*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 tes
showuon commented on pull request #10716:
URL: https://github.com/apache/kafka/pull/10716#issuecomment-843693354
Also, there are code conflict with `trunk` branch. Please merge `trunk` and
push again. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the
showuon commented on pull request #10715:
URL: https://github.com/apache/kafka/pull/10715#issuecomment-843693730
I'll monitor it and let you know when completed. :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
ViE-17-tuoi closed pull request #10721:
URL: https://github.com/apache/kafka/pull/10721
--
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, pl
[
https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347269#comment-17347269
]
NEERAJ VAIDYA commented on KAFKA-12776:
---
Thanks [~ableegoldman]
I'd imagined KIP-
showuon commented on a change in pull request #10714:
URL: https://github.com/apache/kafka/pull/10714#discussion_r634877755
##
File path:
clients/src/test/java/org/apache/kafka/common/utils/ConfigUtilsTest.java
##
@@ -140,4 +144,28 @@ public void testMultipleDeprecations() {
DuongPTIT closed pull request #10685:
URL: https://github.com/apache/kafka/pull/10685
--
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, plea
showuon opened a new pull request #10722:
URL: https://github.com/apache/kafka/pull/10722
Update deprecated methods:
1. `KStream#through(String, Produced)`
2. `KafkaConsumer#poll(long)`
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementa
showuon commented on pull request #10722:
URL: https://github.com/apache/kafka/pull/10722#issuecomment-843715792
@mjsax , could you please review this small PR to update java doc? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
dajac commented on pull request #10326:
URL: https://github.com/apache/kafka/pull/10326#issuecomment-843754057
@lizthegrey Please, excuse me for the delay on this one. I did not have the
time to really look into it.
At the moment, it is not clear to me that the PR actually solves the
[
https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347311#comment-17347311
]
Vitaly Gerasimov commented on KAFKA-10201:
--
What's about to change the kafka "b
abbccdda closed pull request #9311:
URL: https://github.com/apache/kafka/pull/9311
--
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
showuon commented on pull request #10715:
URL: https://github.com/apache/kafka/pull/10715#issuecomment-843766426
Failed test is unrelated and flaky.
```
Build / JDK 15 and Scala 2.13 /
kafka.server.RaftClusterTest.testCreateClusterAndCreateAndManyTopics()
```
--
This is an autom
showuon edited a comment on pull request #10715:
URL: https://github.com/apache/kafka/pull/10715#issuecomment-843766426
@ableegoldman , Failed test is unrelated and flaky. Thanks.
```
Build / JDK 15 and Scala 2.13 /
kafka.server.RaftClusterTest.testCreateClusterAndCreateAndManyTopics(
abbccdda commented on a change in pull request #10700:
URL: https://github.com/apache/kafka/pull/10700#discussion_r634931818
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -1089,8 +1089,8 @@ public void handleSuccessfulResponse(RequestHead
zhaohaidao commented on a change in pull request #10700:
URL: https://github.com/apache/kafka/pull/10700#discussion_r634933714
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -1089,8 +1089,8 @@ public void handleSuccessfulResponse(RequestHe
ableegoldman merged pull request #10715:
URL: https://github.com/apache/kafka/pull/10715
--
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
ableegoldman commented on pull request #10715:
URL: https://github.com/apache/kafka/pull/10715#issuecomment-843771446
Merged to trunk at exactly 11pm PST (May 18th 2021) -- be on the lookout for
any failures on builds kicked off after this time
--
This is an automated message from the Ap
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-9295.
---
Resolution: Fixed
> KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shoul
88 matches
Mail list logo
