[
https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756245#comment-17756245
]
Jinyong Choi commented on KAFKA-15302:
--
I got it.
> Stale value returned when usin
cadonna commented on PR #14227:
URL: https://github.com/apache/kafka/pull/14227#issuecomment-1684911229
Build failures are unrelated:
```
Build / JDK 20 and Scala 2.13 /
kafka.log.remote.RemoteIndexCacheTest.testClose()
Build / JDK 20 and Scala 2.13 /
kafka.network.ConnectionQuotas
cadonna merged PR #14227:
URL: https://github.com/apache/kafka/pull/14227
--
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.
kun98-liu opened a new pull request, #14248:
URL: https://github.com/apache/kafka/pull/14248
## Description
- When I use IntelliJ to debug `kafka.core.main` following the
[wiki](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=145722808),
I kept having error messages like
cadonna closed pull request #14214: KAFKA-10199: Change to RUNNING if no
pending task to init exist
URL: https://github.com/apache/kafka/pull/14214
--
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 th
cadonna opened a new pull request, #14249:
URL: https://github.com/apache/kafka/pull/14249
A stream thread should only change to RUNNING if there are no active tasks
in restoration in the state updater and if there are no pending tasks to
recycle and to init.
Usually all pending task
[
https://issues.apache.org/jira/browse/KAFKA-14138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14138:
-
Assignee: (was: Sagar Rao)
> The Exception Throwing Behavior of Transactional Producer is I
[
https://issues.apache.org/jira/browse/KAFKA-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756308#comment-17756308
]
Sagar Rao commented on KAFKA-14429:
---
hey [~gharris1727], given Chris's comment above,
cadonna commented on code in PR #13927:
URL: https://github.com/apache/kafka/pull/13927#discussion_r1299182368
##
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java:
##
@@ -212,10 +213,11 @@ public void shouldRestoreState() throw
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1299184981
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -696,11 +704,327 @@ public void run() {
}
}
+public void handleLogSt
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1299185257
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -698,11 +707,329 @@ public void run() {
}
}
+public void handleLogSt
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213580
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213610
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213641
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213641
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213816
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213610
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213816
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
olalamichelle commented on code in PR #14078:
URL: https://github.com/apache/kafka/pull/14078#discussion_r1299213816
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -195,4 +231,68 @@ public String getBod
Fei Xie created KAFKA-15382:
---
Summary: Replace EasyMock with Mockito for
KStreamTransformValuesTest
Key: KAFKA-15382
URL: https://issues.apache.org/jira/browse/KAFKA-15382
Project: Kafka
Issue Typ
Fei Xie created KAFKA-15383:
---
Summary: Replace EasyMock with Mockito for KTableImplTest
Key: KAFKA-15383
URL: https://issues.apache.org/jira/browse/KAFKA-15383
Project: Kafka
Issue Type: Sub-task
Fei Xie created KAFKA-15384:
---
Summary: Replace EasyMock with Mockito for
KTableTransformValuesTest
Key: KAFKA-15384
URL: https://issues.apache.org/jira/browse/KAFKA-15384
Project: Kafka
Issue Type
Fei Xie created KAFKA-15385:
---
Summary: Replace EasyMock with Mockito for AbstractStreamTest
Key: KAFKA-15385
URL: https://issues.apache.org/jira/browse/KAFKA-15385
Project: Kafka
Issue Type: Sub-ta
olalamichelle opened a new pull request, #14250:
URL: https://github.com/apache/kafka/pull/14250
As titled.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation
olalamichelle opened a new pull request, #14251:
URL: https://github.com/apache/kafka/pull/14251
As titled.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation
olalamichelle opened a new pull request, #14252:
URL: https://github.com/apache/kafka/pull/14252
As titled.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation
olalamichelle opened a new pull request, #14253:
URL: https://github.com/apache/kafka/pull/14253
As titled.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation
junrao commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1299221576
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -696,11 +704,327 @@ public void run() {
}
}
+public void handleLogSta
cadonna commented on PR #14249:
URL: https://github.com/apache/kafka/pull/14249#issuecomment-1685047002
I got the approval for this PR in https://github.com/apache/kafka/pull/14214.
I opened a new one because all build runs on
https://github.com/apache/kafka/pull/14214 run into a timeout.
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756336#comment-17756336
]
Fei Xie commented on KAFKA-14133:
-
[~christo_lolov] I have created 4 tickets and associ
cadonna merged PR #14249:
URL: https://github.com/apache/kafka/pull/14249
--
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.
rondagostino merged PR #14083:
URL: https://github.com/apache/kafka/pull/14083
--
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.ap
rondagostino commented on PR #14083:
URL: https://github.com/apache/kafka/pull/14083#issuecomment-1685077921
Merged to 3.6
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino resolved KAFKA-15219.
---
Fix Version/s: 3.6.0
Resolution: Fixed
> Support delegation tokens in KRaft
> ---
olalamichelle opened a new pull request, #14254:
URL: https://github.com/apache/kafka/pull/14254
As titled.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation
olalamichelle opened a new pull request, #14255:
URL: https://github.com/apache/kafka/pull/14255
…ToProcessorContextAdapterTest, StreamsProducerTest
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a s
olalamichelle opened a new pull request, #14256:
URL: https://github.com/apache/kafka/pull/14256
…IteratorFacadeTest, KeyValueSegmentTest, TopologyMetadataTest
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message,
olalamichelle opened a new pull request, #14257:
URL: https://github.com/apache/kafka/pull/14257
*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 t
olalamichelle opened a new pull request, #14258:
URL: https://github.com/apache/kafka/pull/14258
*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 t
olalamichelle opened a new pull request, #14259:
URL: https://github.com/apache/kafka/pull/14259
*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 t
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756373#comment-17756373
]
Fei Xie commented on KAFKA-14133:
-
Sent out a few more PRs. All tests until #21
Metered
satishd commented on code in PR #14127:
URL: https://github.com/apache/kafka/pull/14127#discussion_r1299301497
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java:
##
@@ -64,302 +65,393 @@
class ConsumerTask implements Runnable, Closea
satishd commented on code in PR #14127:
URL: https://github.com/apache/kafka/pull/14127#discussion_r1299301497
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java:
##
@@ -64,302 +65,393 @@
class ConsumerTask implements Runnable, Closea
43 matches
Mail list logo
