predatorray commented on pull request #10525:
URL: https://github.com/apache/kafka/pull/10525#issuecomment-1021977962
@guozhangwang Would you mind reviewing this pr for me?
--
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-7572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482323#comment-17482323
]
Wenhao Ji commented on KAFKA-7572:
--
[~guozhang] Would you mind reviewing the pr
[#10525
[
https://issues.apache.org/jira/browse/KAFKA-13617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482351#comment-17482351
]
Nicolas Guyomar commented on KAFKA-13617:
-
Hi [~joecqupt] , indeed I'll edit my
[
https://issues.apache.org/jira/browse/KAFKA-13617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Guyomar updated KAFKA-13617:
Description:
Hi team,
When you try to understand why a consumer group offset was expired,
mimaison merged pull request #11508:
URL: https://github.com/apache/kafka/pull/11508
--
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
[
https://issues.apache.org/jira/browse/KAFKA-9279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-9279.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> Silent data loss in Kafka producer
>
mimaison commented on a change in pull request #11382:
URL: https://github.com/apache/kafka/pull/11382#discussion_r792539420
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -364,9 +365,16 @@ private boolean sendRecords()
Kvicii.Yu created KAFKA-13618:
-
Summary: BatchAccumulator `Exptected` rename to `Expected`
Key: KAFKA-13618
URL: https://issues.apache.org/jira/browse/KAFKA-13618
Project: Kafka
Issue Type: Impro
showuon commented on pull request #11705:
URL: https://github.com/apache/kafka/pull/11705#issuecomment-1022206850
@mjsax , I know the KIP is still having discussion about the `Stores` API.
But I think the PR is ready for pre-review right now (if you have time :)).
For the `Stores` AP
showuon edited a comment on pull request #11705:
URL: https://github.com/apache/kafka/pull/11705#issuecomment-1022206850
@mjsax , I know the KIP is still under discussion about the `Stores` API.
But I think the PR is ready for pre-review right now (if you have time :)).
For the `Stor
Kvicii opened a new pull request #11715:
URL: https://github.com/apache/kafka/pull/11715
BatchAccumulator `Exptected` rename to `Expected`
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build statu
showuon commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r792651448
##
File path:
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java
##
@@ -226,6 +227,11 @@ public Password getPassword(String key) {
Kvicii commented on pull request #11715:
URL: https://github.com/apache/kafka/pull/11715#issuecomment-1022211436
@showuon hi, cloud you help me.
PTAL
--
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
showuon commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r792653054
##
File path:
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java
##
@@ -24,14 +24,15 @@
import org.slf4j.LoggerFactory;
import or
showuon commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r792657463
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
##
@@ -170,6 +170,7 @@ public void configure(fi
showuon commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r792658808
##
File path:
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
##
@@ -2383,6 +2384,7 @@ class AuthorizerIntegrationTest extends
Tomonari Yamashita created KAFKA-13619:
--
Summary: zookeeper.sync.time.ms is no longer used
Key: KAFKA-13619
URL: https://issues.apache.org/jira/browse/KAFKA-13619
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-13619:
---
Component/s: core
documentation
> zookeeper.sync.time.ms is no long
showuon commented on a change in pull request #11691:
URL: https://github.com/apache/kafka/pull/11691#discussion_r792663973
##
File path:
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala
##
@@ -352,20 +359,28 @@ abstract class EndToEndAuthorizationTest
[
https://issues.apache.org/jira/browse/KAFKA-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-13619:
---
Description:
- zookeeper.sync.time.ms is no longer used. But it is present in the
d
vvcephei commented on pull request #11682:
URL: https://github.com/apache/kafka/pull/11682#issuecomment-1022316812
Unrelated test failures:
```
Build / ARM /
kafka.server.ReplicaManagerTest.testDeltaFromLeaderToFollower()
Build / JDK 8 and Scala 2.12 / kafka.admin.LeaderEle
vvcephei merged pull request #11682:
URL: https://github.com/apache/kafka/pull/11682
--
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
dajac opened a new pull request #11716:
URL: https://github.com/apache/kafka/pull/11716
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade not
dajac commented on pull request #11716:
URL: https://github.com/apache/kafka/pull/11716#issuecomment-1022337985
Run: https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4762/
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
mimaison commented on pull request #11715:
URL: https://github.com/apache/kafka/pull/11715#issuecomment-1022424951
Thanks @Kvicii
For such small changes you don't need to create a JIRA. Just prefix your
commit with `MINOR: `.
--
This is an automated message from the Apache Git Servic
mimaison merged pull request #11715:
URL: https://github.com/apache/kafka/pull/11715
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-13618.
Fix Version/s: 3.2.0
Resolution: Fixed
> BatchAccumulator `Exptected` rename to `Ex
mimaison commented on pull request #11599:
URL: https://github.com/apache/kafka/pull/11599#issuecomment-1022438866
@dajac Do you want to 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 the
UR
Colin McCabe created KAFKA-13620:
Summary: The request handler metric name for ControllerApis should
be different than KafkaApis
Key: KAFKA-13620
URL: https://issues.apache.org/jira/browse/KAFKA-13620
Jose Armando Garcia Sancio created KAFKA-13621:
--
Summary: Resign leader on partition
Key: KAFKA-13621
URL: https://issues.apache.org/jira/browse/KAFKA-13621
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-13621:
---
Summary: Resign leader on network partition (was: Resign leader on
[
https://issues.apache.org/jira/browse/KAFKA-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482729#comment-17482729
]
Jason Gustafson commented on KAFKA-13612:
-
[~dnwe] I agree with you that computi
hachikuji merged pull request #11693:
URL: https://github.com/apache/kafka/pull/11693
--
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-unsubsc
[
https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482745#comment-17482745
]
Jason Gustafson commented on KAFKA-13621:
-
[~guozhang] I seem to recall that we
splett2 commented on pull request #11671:
URL: https://github.com/apache/kafka/pull/11671#issuecomment-1022640040
thanks for fixing this!
--
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 spec
junrao commented on pull request #11345:
URL: https://github.com/apache/kafka/pull/11345#issuecomment-1022654522
@ccding : There is a conflict now. Could you rebase?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
TheKnowles commented on a change in pull request #11382:
URL: https://github.com/apache/kafka/pull/11382#discussion_r793104719
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -364,9 +365,16 @@ private boolean sendRecords
TheKnowles commented on a change in pull request #11382:
URL: https://github.com/apache/kafka/pull/11382#discussion_r793104806
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -364,9 +365,16 @@ private boolean sendRecords
TheKnowles commented on a change in pull request #11382:
URL: https://github.com/apache/kafka/pull/11382#discussion_r793104975
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java
##
@@ -111,6 +111,23 @@ public Ret
TheKnowles commented on pull request #11382:
URL: https://github.com/apache/kafka/pull/11382#issuecomment-1022663365
> Thanks @TheKnowles for the PR. I've made a first pass and left a few
comments.
@mimaison Thank you for reviewing. I've replied to each comment above and
pushed chan
C0urante commented on a change in pull request #11382:
URL: https://github.com/apache/kafka/pull/11382#discussion_r793112244
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -364,9 +365,16 @@ private boolean sendRecords()
Kvicii commented on pull request #11715:
URL: https://github.com/apache/kafka/pull/11715#issuecomment-1022676092
@mimaison OK
--
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
vvcephei commented on a change in pull request #11676:
URL: https://github.com/apache/kafka/pull/11676#discussion_r793196902
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java
##
@@ -85,8 +85,23 @@
* @throws IllegalStateException
vvcephei commented on a change in pull request #11676:
URL: https://github.com/apache/kafka/pull/11676#discussion_r793198150
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java
##
@@ -44,9 +43,12 @@
public void init(final
vvcephei commented on a change in pull request #11676:
URL: https://github.com/apache/kafka/pull/11676#discussion_r793212425
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java
##
@@ -85,8 +85,23 @@
* @throws IllegalStateException
vvcephei commented on a change in pull request #11676:
URL: https://github.com/apache/kafka/pull/11676#discussion_r793214036
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java
##
@@ -152,4 +153,11 @@ default void init(final StateStoreContext
vvcephei commented on a change in pull request #11676:
URL: https://github.com/apache/kafka/pull/11676#discussion_r793216634
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
##
@@ -264,8 +267,12 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-13605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13605:
-
Parent: KAFKA-13479
Issue Type: Sub-task (was: Improvement)
> Checkpoint position in st
[
https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-13524:
Assignee: Vicky Papavasileiou
> IQv2: Implement KeyQuery from the RecordCache
> -
[
https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13524.
--
Resolution: Fixed
> IQv2: Implement KeyQuery from the RecordCache
> --
[
https://issues.apache.org/jira/browse/KAFKA-13608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482866#comment-17482866
]
John Roesler commented on KAFKA-13608:
--
Ah, I didn't realize there was a ticket for
[
https://issues.apache.org/jira/browse/KAFKA-13608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-13608.
--
Resolution: Duplicate
> Implement Position restoration for all in-memory state stores
> --
John Roesler created KAFKA-13622:
Summary: Revisit the complexity of position tracking in state
stores
Key: KAFKA-13622
URL: https://issues.apache.org/jira/browse/KAFKA-13622
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13622:
-
Priority: Blocker (was: Major)
> Revisit the complexity of position tracking in state stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13554:
-
Priority: Blocker (was: Major)
> Rename RangeQuery to KeyRangeQuery
> -
[
https://issues.apache.org/jira/browse/KAFKA-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13554:
-
Affects Version/s: 3.2.0
> Rename RangeQuery to KeyRangeQuery
>
[
https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13526:
-
Affects Version/s: 3.2.0
> IQv2: Consider more generic logic for mapping between binary and type
[
https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13548:
-
Affects Version/s: 3.2.0
> IQv2: revisit WindowKeyQuery and WindowRangeQuery
> -
[
https://issues.apache.org/jira/browse/KAFKA-13523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13523:
-
Priority: Blocker (was: Major)
> Implement IQv2 support in global stores
>
[
https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13541:
-
Priority: Blocker (was: Major)
> Make IQv2 query/store interface type safe
> --
[
https://issues.apache.org/jira/browse/KAFKA-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13622:
-
Affects Version/s: 3.2.0
> Revisit the complexity of position tracking in state stores
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13541:
-
Affects Version/s: 3.2.0
> Make IQv2 query/store interface type safe
> -
[
https://issues.apache.org/jira/browse/KAFKA-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13548:
-
Priority: Blocker (was: Major)
> IQv2: revisit WindowKeyQuery and WindowRangeQuery
> --
[
https://issues.apache.org/jira/browse/KAFKA-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13526:
-
Priority: Blocker (was: Major)
> IQv2: Consider more generic logic for mapping between binary a
vvcephei commented on a change in pull request #11676:
URL: https://github.com/apache/kafka/pull/11676#discussion_r793249432
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java
##
@@ -85,8 +85,23 @@
* @throws IllegalStateException
[
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: 3.2.0
> Implement IQv2 support in global stores
> ---
dajac merged pull request #11714:
URL: https://github.com/apache/kafka/pull/11714
--
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...
[
https://issues.apache.org/jira/browse/KAFKA-13614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-13614.
-
Fix Version/s: 3.2.0
Reviewer: David Jacot
Resolution: Fixed
> Leader replicatio
[
https://issues.apache.org/jira/browse/KAFKA-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-13619:
---
Description:
- zookeeper.sync.time.ms is no longer used. But it is present in the
d
[
https://issues.apache.org/jira/browse/KAFKA-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-13619:
---
Description:
- zookeeper.sync.time.ms is no longer used. But it is present in the
d
70 matches
Mail list logo
