ijuma commented on a change in pull request #11025:
URL: https://github.com/apache/kafka/pull/11025#discussion_r668782203
##
File path: Jenkinsfile
##
@@ -181,6 +181,25 @@ pipeline {
}
}
+stage('JDK 11 and Scala 3.0') {
Review comment:
For
dajac commented on a change in pull request #11019:
URL: https://github.com/apache/kafka/pull/11019#discussion_r668781007
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java
##
@@ -100,51 +100,115 @@ public String
showuon commented on a change in pull request #11019:
URL: https://github.com/apache/kafka/pull/11019#discussion_r668780259
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java
##
@@ -100,51 +100,115 @@ public Stri
jlprat commented on a change in pull request #11025:
URL: https://github.com/apache/kafka/pull/11025#discussion_r668779835
##
File path: Jenkinsfile
##
@@ -181,6 +181,25 @@ pipeline {
}
}
+stage('JDK 11 and Scala 3.0') {
Review comment:
Mak
jlprat commented on a change in pull request #11025:
URL: https://github.com/apache/kafka/pull/11025#discussion_r668778973
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala
##
@@ -790,7 +790,7 @@ class KStream[K, V](val inn
ijuma commented on pull request #11025:
URL: https://github.com/apache/kafka/pull/11025#issuecomment-879100667
Thanks for the PR. Are we sure everything works correctly at the zinc level?
Someone mentioned a zinc upgrade here
https://github.com/gradle/gradle/issues/16527. The 3.1 release i
ijuma commented on a change in pull request #11025:
URL: https://github.com/apache/kafka/pull/11025#discussion_r668774761
##
File path: Jenkinsfile
##
@@ -181,6 +181,25 @@ pipeline {
}
}
+stage('JDK 11 and Scala 3.0') {
Review comment:
We w
ijuma commented on a change in pull request #11025:
URL: https://github.com/apache/kafka/pull/11025#discussion_r668774185
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala
##
@@ -790,7 +790,7 @@ class KStream[K, V](val inne
dajac commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668772378
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.confi
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668733930
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.con
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668733930
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.con
dajac commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668766346
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.confi
[
https://issues.apache.org/jira/browse/KAFKA-12954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379887#comment-17379887
]
Josep Prat commented on KAFKA-12954:
Forgot to mention, this is the PR where Scala 3
dongjinleekr commented on pull request #10827:
URL: https://github.com/apache/kafka/pull/10827#issuecomment-879085051
@kkonstantine It would be really great for me if this PR is included in 3.0,
but it still needs one more binding +1. (It is also why it is prefixed with
'[WIP]'.) Could you
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668752416
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.con
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668752416
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.con
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668733930
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.con
[
https://issues.apache.org/jira/browse/KAFKA-12656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379871#comment-17379871
]
Angelos Kaltsikis commented on KAFKA-12656:
---
Hey [~liangx],
Thanks for opening
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668733930
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.con
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668733930
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,23 @@ object ConsoleConsumer extends Logging {
formatter.con
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668733381
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -191,9 +191,15 @@ object ConsoleConsumer extends Logging {
.withRequiredA
dongjinleekr commented on a change in pull request #11007:
URL: https://github.com/apache/kafka/pull/11007#discussion_r668731566
##
File path: core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala
##
@@ -89,11 +89,16 @@ object ReplicaVerificationTool extends Logging {
dajac commented on a change in pull request #11019:
URL: https://github.com/apache/kafka/pull/11019#discussion_r668728522
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java
##
@@ -100,51 +100,115 @@ public String
dajac commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r668716740
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -191,9 +191,15 @@ object ConsoleConsumer extends Logging {
.withRequiredArg
showuon commented on pull request #11009:
URL: https://github.com/apache/kafka/pull/11009#issuecomment-879049924
Previous build has one test group timeout. Re-trigger it again.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
dongjinleekr commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-879046873
@emveee Thank you so much for being so interested. 2.8.0 backport preview
will be released this week.
--
This is an automated message from the Apache Git Service.
To respon
cadonna commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-879032262
@lkokhreidze Sorry for the long silence! Some other tasks got in my way. I
plan to review this PR tomorrow.
--
This is an automated message from the Apache Git Service.
To
showuon closed pull request #10559:
URL: https://github.com/apache/kafka/pull/10559
--
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.
showuon commented on pull request #10559:
URL: https://github.com/apache/kafka/pull/10559#issuecomment-879029730
close this PR since the root cause is fixed.
--
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
OmniaGM commented on pull request #11007:
URL: https://github.com/apache/kafka/pull/11007#issuecomment-879026189
@gwenshap (or any other committer) can you please have a look into this?
Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kashavkin updated KAFKA-13055:
-
Description:
I think that this isn't a bug, but I don't know what type to choose for thi
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kashavkin updated KAFKA-13055:
-
Comment: was deleted
(was: {code:bash}
listener.name.clients.scram-sha-256.sasl.jaas.con
cadonna commented on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-878999564
I think we had a bug in the `SessionWindows` because we have never
considered a user set grace period when we computed the retention time. That
should be fixed with the new API,
cadonna edited a comment on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-878965687
> However, looking into the code I am a little bit confused about
maintainMs() in TimeWindows:
>
```
public long maintainMs() {
return Math.max(maintainDu
cadonna commented on a change in pull request #10944:
URL: https://github.com/apache/kafka/pull/10944#discussion_r668643843
##
File path: tests/kafkatest/tests/streams/streams_eos_test.py
##
@@ -128,45 +128,61 @@ def run_failure_and_recovery(self, processor1,
processor2, proce
tombentley commented on pull request #10945:
URL: https://github.com/apache/kafka/pull/10945#issuecomment-878974936
LGTM.
--
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
cadonna commented on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-878965687
> However, looking into the code I am a little bit confused about
maintainMs() in TimeWindows:
>
```
public long maintainMs() {
return Math.max(maintainDurationM
cadonna edited a comment on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-878835507
> I don't see how there could be data loss?
There could be data loss, because locally the windowed state store would
store records for a longer period of time than
showuon commented on pull request #10884:
URL: https://github.com/apache/kafka/pull/10884#issuecomment-878942836
Interesting. I'll take a 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
URL above to
showuon commented on pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#issuecomment-878942169
I've split this PR into 5 sub-PRs:
https://github.com/apache/kafka/pull/11019 for
DeleteConsumerGroupOffsetsHandler
https://github.com/apache/kafka/pull/11021 for Delet
showuon commented on pull request #11035:
URL: https://github.com/apache/kafka/pull/11035#issuecomment-878939627
@dajac , please take a 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
URL above to go
showuon opened a new pull request #11035:
URL: https://github.com/apache/kafka/pull/11035
Some issues found in the RemoveMembersFromConsumerGroupHandler:
1. if coordinator errors is put in the member, we don't do retry. Fix it and
add tests
This is the old handle response logic. F
[
https://issues.apache.org/jira/browse/KAFKA-13058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13058:
Fix Version/s: 3.0.0
> `AlterConsumerGroupOffsetsHandler` does not handle partition errors correct
showuon commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r668516397
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -218,70 +253,87 @@ private boolean allS
showuon commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r668514017
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -205,6 +237,9 @@ private boolean allSub
jlprat commented on a change in pull request #10987:
URL: https://github.com/apache/kafka/pull/10987#discussion_r668507450
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -234,7 +234,24 @@
/** partitioner.class */
pub
showuon commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r668510115
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -205,6 +237,9 @@ private boolean allSub
[
https://issues.apache.org/jira/browse/KAFKA-13076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
label updated KAFKA-13076:
--
Issue Type: Bug (was: Improvement)
> cannot consumer
> ---
>
> Key: KAFKA-13076
>
[
https://issues.apache.org/jira/browse/KAFKA-13076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
label updated KAFKA-13076:
--
Issue Type: Improvement (was: Bug)
> cannot consumer
> ---
>
> Key: KAFKA-13076
>
[
https://issues.apache.org/jira/browse/KAFKA-13076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
label updated KAFKA-13076:
--
Priority: Blocker (was: Major)
> cannot consumer
> ---
>
> Key: KAFKA-13076
>
[
https://issues.apache.org/jira/browse/KAFKA-13076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
label updated KAFKA-13076:
--
Attachment: zookeeper.properties
server.properties
> cannot consumer
> ---
>
>
label created KAFKA-13076:
-
Summary: cannot consumer
Key: KAFKA-13076
URL: https://issues.apache.org/jira/browse/KAFKA-13076
Project: Kafka
Issue Type: Bug
Components: consumer
Affects
[
https://issues.apache.org/jira/browse/KAFKA-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379665#comment-17379665
]
DEBENDRA DHINDA commented on KAFKA-8549:
Is it resolved ?
> Kafka Windows start
cadonna edited a comment on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-878835507
> I don't see how there could be data loss?
There could be data loss, because locally the windowed state store would
store records for a longer period of time than
cadonna commented on pull request #10953:
URL: https://github.com/apache/kafka/pull/10953#issuecomment-878835507
> I don't see how there could be data loss?
There could be data loss, because locally the windowed state store would
store records for a longer period of time than in the chan
[
https://issues.apache.org/jira/browse/KAFKA-12795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pengWei Dou resolved KAFKA-12795.
-
Resolution: Won't Fix
> Create kafka connector use chinese character failed
> --
201 - 256 of 256 matches
Mail list logo
