ableegoldman commented on PR #11490:
URL: https://github.com/apache/kafka/pull/11490#issuecomment-1091108680
Hey @showuon I just noticed that the deprecation warning here was in the
general `upgrade.html` and not in the Streams `upgrade-guide.html` -- since we
are only "deprecating" the
showuon commented on code in PR #12007:
URL: https://github.com/apache/kafka/pull/12007#discussion_r844631567
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java:
##
@@ -617,7 +617,7 @@ public synchronized void
showuon commented on code in PR #12006:
URL: https://github.com/apache/kafka/pull/12006#discussion_r844630559
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -187,7 +187,7 @@ private void
showuon commented on code in PR #11991:
URL: https://github.com/apache/kafka/pull/11991#discussion_r844630822
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -184,16 +184,22 @@ private void
karuturi commented on PR #11955:
URL: https://github.com/apache/kafka/pull/11955#issuecomment-1091055109
Hi @showuon
As there is no response on the other PR, can we take this forward?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
bozhao12 commented on code in PR #12007:
URL: https://github.com/apache/kafka/pull/12007#discussion_r844610818
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java:
##
@@ -617,7 +617,7 @@ public synchronized void
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13479.
--
Fix Version/s: 3.2.0
Resolution: Fixed
> Interactive Query v2
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler closed KAFKA-13479.
> Interactive Query v2
>
>
> Key: KAFKA-13479
>
[
https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13622:
-
Parent: (was: KAFKA-13479)
Issue Type: Improvement (was: Sub-task)
> Revisit the
[
https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13548:
-
Parent: (was: KAFKA-13479)
Issue Type: Improvement (was: Sub-task)
> IQv2: revisit
[
https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13622:
-
Labels: IQv2 (was: )
> Revisit the complexity of position tracking in state stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13622:
-
Component/s: streams
> Revisit the complexity of position tracking in state stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13548:
-
Component/s: streams
> IQv2: revisit WindowKeyQuery and WindowRangeQuery
>
[
https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13541:
-
Parent: (was: KAFKA-13479)
Issue Type: Improvement (was: Sub-task)
> Make IQv2
[
https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13548:
-
Labels: IQv2 (was: )
> IQv2: revisit WindowKeyQuery and WindowRangeQuery
>
[
https://issues.apache.org/jira/browse/KAFKA-13479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518567#comment-17518567
]
John Roesler commented on KAFKA-13479:
--
Sorry about that, [~cadonna] . I'll do it now.
All the
[
https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13541:
-
Component/s: streams
> Make IQv2 query/store interface type safe
>
[
https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13541:
-
Labels: IQv2 (was: )
> Make IQv2 query/store interface type safe
>
[
https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13526:
-
Labels: IQv2 (was: )
> IQv2: Consider more generic logic for mapping between binary and typed
[
https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13526:
-
Parent: (was: KAFKA-13479)
Issue Type: Improvement (was: Sub-task)
> IQv2:
[
https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13526:
-
Component/s: streams
> IQv2: Consider more generic logic for mapping between binary and typed
[
https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13523:
-
Priority: Major (was: Blocker)
> Implement IQv2 support in global stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13523:
-
Affects Version/s: (was: 3.2.0)
> Implement IQv2 support in global stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13523:
-
Component/s: streams
> Implement IQv2 support in global stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13523:
-
Parent: (was: KAFKA-13479)
Issue Type: Improvement (was: Sub-task)
> Implement
[
https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13523:
-
Labels: IQv2 (was: )
> Implement IQv2 support in global stores
>
showuon commented on code in PR #12007:
URL: https://github.com/apache/kafka/pull/12007#discussion_r844586419
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java:
##
@@ -617,7 +617,7 @@ public synchronized void
bozhao12 opened a new pull request, #12007:
URL: https://github.com/apache/kafka/pull/12007
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
bozhao12 closed pull request #12002: MINOR: Fix typo and method annotation
URL: https://github.com/apache/kafka/pull/12002
--
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
ddrid commented on PR #11979:
URL: https://github.com/apache/kafka/pull/11979#issuecomment-1090995487
Hi @showuon, could you take another look if you have time? thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
ddrid commented on PR #12006:
URL: https://github.com/apache/kafka/pull/12006#issuecomment-1090993473
also cc @hachikuji
--
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.
ddrid commented on PR #12006:
URL: https://github.com/apache/kafka/pull/12006#issuecomment-1090991057
Hi @artemlivshits, please take a look if you have time
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ddrid opened a new pull request, #12006:
URL: https://github.com/apache/kafka/pull/12006
Follow up to original PR #11991
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
ddrid commented on code in PR #11991:
URL: https://github.com/apache/kafka/pull/11991#discussion_r844559833
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -184,16 +184,22 @@ private void
[
https://issues.apache.org/jira/browse/KAFKA-13803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kowshik Prakasam reassigned KAFKA-13803:
Assignee: Rittika Adhikari
> Refactor Leader API Access
>
[
https://issues.apache.org/jira/browse/KAFKA-13601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-13601.
---
Resolution: Won't Do
> Add option to support sync offset commit in Kafka Connect Sink
>
[
https://issues.apache.org/jira/browse/KAFKA-13803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rittika Adhikari updated KAFKA-13803:
-
Reviewer: Jun Rao
> Refactor Leader API Access
> --
>
>
rittikaadhikari opened a new pull request, #12005:
URL: https://github.com/apache/kafka/pull/12005
This PR refactors the leader API access in the follower fetch path.
Added a `LeaderEndPoint` interface which serves all access to the leader.
Added a `LocalLeaderEndPoint` and a
Rittika Adhikari created KAFKA-13803:
Summary: Refactor Leader API Access
Key: KAFKA-13803
URL: https://issues.apache.org/jira/browse/KAFKA-13803
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kowshik Prakasam updated KAFKA-13603:
-
Issue Type: Improvement (was: Bug)
> empty active segment can trigger recovery after
[
https://issues.apache.org/jira/browse/KAFKA-13603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kowshik Prakasam updated KAFKA-13603:
-
Priority: Major (was: Minor)
> empty active segment can trigger recovery after clean
artemlivshits commented on code in PR #11991:
URL: https://github.com/apache/kafka/pull/11991#discussion_r85963
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -184,16 +184,22 @@ private void
xvrl commented on code in PR #11998:
URL: https://github.com/apache/kafka/pull/11998#discussion_r844114172
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -800,12 +800,15 @@ class DynamicMetricsReporters(brokerId: Int, server:
KafkaBroker) extends Reconf
[
https://issues.apache.org/jira/browse/KAFKA-13687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-13687.
-
Fix Version/s: 3.3.0
Resolution: Fixed
merged the PR to trunk.
> Limit number of batches when
junrao merged PR #11842:
URL: https://github.com/apache/kafka/pull/11842
--
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:
dotjdk commented on PR #10390:
URL: https://github.com/apache/kafka/pull/10390#issuecomment-1090378567
Yes. I have seen the PR, and that fixes the misleading parameter names
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
dajac commented on code in PR #11998:
URL: https://github.com/apache/kafka/pull/11998#discussion_r844038546
##
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala:
##
@@ -800,12 +800,15 @@ class DynamicMetricsReporters(brokerId: Int, server:
KafkaBroker) extends Reconf
ijuma merged PR #11984:
URL: https://github.com/apache/kafka/pull/11984
--
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:
dajac merged PR #11996:
URL: https://github.com/apache/kafka/pull/11996
--
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:
bozhao12 closed pull request #12002: MINOR: Fix typo and method annotation
URL: https://github.com/apache/kafka/pull/12002
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-12774.
---
Resolution: Cannot Reproduce
> kafka-streams 2.8: logging in uncaught-exceptionhandler
divijvaidya opened a new pull request, #12004:
URL: https://github.com/apache/kafka/pull/12004
### Changes:
Add a stricter assertion in LogCleanerManagerTest
Minor cosmetic simplification in Scala
### Testing:
LogCleanerManagerTest run is successful. All unit test runs
divijvaidya closed pull request #11943: KAFKA-10095: Add stricter assertion in
LogCleanerManagerTest
URL: https://github.com/apache/kafka/pull/11943
--
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
divijvaidya commented on PR #11943:
URL: https://github.com/apache/kafka/pull/11943#issuecomment-1090310433
The failing test in the PR builder `PurgeRepartitionTopicIntegrationTest`
which should have been fixed as part of #11948. I will rebase this PR with
latest so that the tests pass.
bbejeck commented on PR #11980:
URL: https://github.com/apache/kafka/pull/11980#issuecomment-1090294179
merged #11980 into 3.1
--
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
bbejeck merged PR #11980:
URL: https://github.com/apache/kafka/pull/11980
--
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:
bbejeck commented on PR #11980:
URL: https://github.com/apache/kafka/pull/11980#issuecomment-1090287822
Failure unrelated `Build / JDK 8 and Scala 2.12 /
kafka.admin.LeaderElectionCommandTest.[1] Type=Raft,
Name=testElectionResultOutput, Security=PLAINTEXT`
--
This is an automated
clayburn opened a new pull request, #12003:
URL: https://github.com/apache/kafka/pull/12003
Fix UP-TO-DATE check in `create*VersionFile` tasks - `create*VersionFile`
tasks explicitly declared output UP-TO-DATE status as being false. This change
properly sets the inputs to
ijuma commented on PR #11984:
URL: https://github.com/apache/kafka/pull/11984#issuecomment-1090245276
Build passed apart from one flake in the PowerPC build:
> Build / PowerPC /
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518103#comment-17518103
]
Luke Chen commented on KAFKA-13793:
---
Please submit a PR for it. It is a straightforward fix. Thanks.
jlprat commented on PR #11432:
URL: https://github.com/apache/kafka/pull/11432#issuecomment-1090171551
@ijuma @cadonna do you think it makes sense to review 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
[
https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518039#comment-17518039
]
Patrik Kleindl commented on KAFKA-12909:
[~mjsax] Is it planned to un-deprecate the previous
aCoder2013 commented on PR #12002:
URL: https://github.com/apache/kafka/pull/12002#issuecomment-1090142654
这是来自QQ邮箱的假期自动回复邮件。
您好，我最近正在休假中，无法亲自回复您的邮件。我将在假期结束后，尽快给您回复。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
bozhao12 opened a new pull request, #12002:
URL: https://github.com/apache/kafka/pull/12002
Fix typo in Fetcher.java and method annotation in SubscriptionState.java
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
tombentley merged PR #12001:
URL: https://github.com/apache/kafka/pull/12001
--
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:
tombentley opened a new pull request, #12001:
URL: https://github.com/apache/kafka/pull/12001
Update release notes for 3.1.1
--
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.
mimaison commented on PR #9794:
URL: https://github.com/apache/kafka/pull/9794#issuecomment-1090063774
@samarthd We added aarch64 to the Kafka CI in
https://github.com/apache/kafka/pull/9992
--
This is an automated message from the Apache Git Service.
To respond to the message,
tombentley merged PR #11994:
URL: https://github.com/apache/kafka/pull/11994
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517978#comment-17517978
]
Josep Prat commented on KAFKA-12319:
jlprat commented on PR #11432:
URL: https://github.com/apache/kafka/pull/11432#issuecomment-1090043633
At least one of the failures was:
https://issues.apache.org/jira/browse/KAFKA-12319
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-13802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stéphane Loeuillet updated KAFKA-13802:
---
Environment:
Ubuntu 20.04.3
Adoptium 17.0.2_8
Kafka 2.13_3.1.0 with message format
[
https://issues.apache.org/jira/browse/KAFKA-13802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stéphane Loeuillet updated KAFKA-13802:
---
Environment:
Ubuntu 20.04.3
Adoptium 17.0.2_8
Kafka 2.13_3.1.0 with message format
[
https://issues.apache.org/jira/browse/KAFKA-13802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stéphane Loeuillet updated KAFKA-13802:
---
Environment:
Ubuntu 20.04.3
Adoptium 17.0.2_8
Kafka 2.13_3.1.0 with message format
Stéphane Loeuillet created KAFKA-13802:
--
Summary: Uncaught exception in scheduled task 'flush-log'
(kafka.utils.KafkaScheduler)
Key: KAFKA-13802
URL: https://issues.apache.org/jira/browse/KAFKA-13802
RivenSun2 commented on PR #12000:
URL: https://github.com/apache/kafka/pull/12000#issuecomment-1089895131
Hi @showuon @mimaison
Using the `internal.leave.group.on.close` string directly in the code will
make people confused. It is recommended to use LEAVE_GROUP_ON_CLOSE_CONFIG
RivenSun2 opened a new pull request, #12000:
URL: https://github.com/apache/kafka/pull/12000
Use the LEAVE_GROUP_ON_CLOSE_CONFIG configuration uniformly to avoid
multiple codes using the `internal.leave.group.on.close` string alone
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517866#comment-17517866
]
Jørgen commented on KAFKA-12774:
[~cadonna] : Sounds good to me. We still have the issue, but I'm not
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472
]
RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM:
--
I combed through all
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472
]
RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM:
--
I combed through all
[
https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516472#comment-17516472
]
RivenSun edited comment on KAFKA-13793 at 4/6/22 6:26 AM:
--
I combed through all
80 matches
Mail list logo
