[
https://issues.apache.org/jira/browse/KAFKA-13061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
geekyouth updated KAFKA-13061:
--
Description:
Caused by: org.apache.spark.sql.streaming.StreamingQueryException:
geekyouth created KAFKA-13061:
-
Summary: spark kafka offset missed some partition offset describle
Key: KAFKA-13061
URL: https://issues.apache.org/jira/browse/KAFKA-13061
Project: Kafka
Issue
satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r667427888
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java
##
@@ -0,0 +1,432 @@
+/*
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667526957
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,14 @@ object ConsoleConsumer extends Logging {
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667511546
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,14 @@ object ConsoleConsumer extends Logging {
Chun-Hao Tang created KAFKA-13060:
-
Summary: Replace EasyMock and PowerMock with Mockito in
WorkerGroupMemberTest.java
Key: KAFKA-13060
URL: https://issues.apache.org/jira/browse/KAFKA-13060
Project:
tang7526 opened a new pull request #11018:
URL: https://github.com/apache/kafka/pull/11018
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667511546
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,14 @@ object ConsoleConsumer extends Logging {
tang7526 commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r667512077
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -246,12 +246,12 @@ State setState(final State
tang7526 commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r667511730
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -939,7 +939,7 @@ private StreamThread
OmniaGM commented on a change in pull request #11008:
URL: https://github.com/apache/kafka/pull/11008#discussion_r667511546
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -315,11 +321,14 @@ object ConsoleConsumer extends Logging {
ijuma commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667506307
##
File path: docs/upgrade.html
##
@@ -21,6 +21,10 @@
Notable changes in
3.0.0
+Custom principal builder implementations specified through
ijuma commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667506596
##
File path:
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalSerde.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
ueisele commented on pull request #10935:
URL: https://github.com/apache/kafka/pull/10935#issuecomment-877829585
I checked the tests which are failing. For me it looks like they are not
related to the change made in this pull request.
What is failing is
ijuma commented on a change in pull request #11011:
URL: https://github.com/apache/kafka/pull/11011#discussion_r667506307
##
File path: docs/upgrade.html
##
@@ -21,6 +21,10 @@
Notable changes in
3.0.0
+Custom principal builder implementations specified through
ueisele commented on a change in pull request #10935:
URL: https://github.com/apache/kafka/pull/10935#discussion_r667498348
##
File path: core/src/test/scala/integration/kafka/server/RaftClusterTest.scala
##
@@ -313,4 +318,94 @@ class RaftClusterTest {
cluster.close()
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378655#comment-17378655
]
Alexey Kashavkin edited comment on KAFKA-13055 at 7/11/21, 1:55 PM:
Luke Chen created KAFKA-13059:
-
Summary: update for DeleteConsumerGroupOffsetsHandler
Key: KAFKA-13059
URL: https://issues.apache.org/jira/browse/KAFKA-13059
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378657#comment-17378657
]
meher ben ahmed commented on KAFKA-12851:
-
it s working fine !Capture.PNG!
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
meher ben ahmed updated KAFKA-12851:
Attachment: Capture.PNG
> Flaky Test
dajac commented on pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#issuecomment-877800572
Sounds good, thanks! I will review them directly. Let's get them in 3.0.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378655#comment-17378655
]
Alexey Kashavkin edited comment on KAFKA-13055 at 7/11/21, 1:20 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378655#comment-17378655
]
Alexey Kashavkin commented on KAFKA-13055:
--
{code:bash}
showuon edited a comment on pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#issuecomment-877797171
> I wonder if we could split up this PR by handler.
Sounds good to me. I can split them tomorrow(my time). There are 6 handlers
added in KIP-699, I'll split into 5
showuon commented on pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#issuecomment-877797171
> I wonder if we could split up this PR by handler.
Sounds good to me. I can split them tomorrow. There are 6 handlers added in
KIP-699, I'll split into 5 PR, and plus
dajac commented on a change in pull request #11016:
URL: https://github.com/apache/kafka/pull/11016#discussion_r667478130
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java
##
@@ -48,23 +46,19 @@
public KafkaFuture
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kashavkin updated KAFKA-13055:
-
Description:
I'm setting up kafka security with multiple listeners. Listener for broker
dajac commented on pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#issuecomment-877795034
@showuon I wonder if we could split up this PR by handler. We've already
have few regressions related to KIP-699 changes so I'd like to be extra careful
and review them all
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kashavkin updated KAFKA-13055:
-
Description:
I'm setting up kafka security with multiple listeners. Listener for broker
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kashavkin updated KAFKA-13055:
-
Summary: Security without JAAS configuration (was: Security without JAAS
file)
>
showuon commented on a change in pull request #11016:
URL: https://github.com/apache/kafka/pull/11016#discussion_r667475174
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java
##
@@ -75,22 +69,19 @@ public void accept(final
showuon edited a comment on pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#issuecomment-877791048
@dajac , thanks for letting me know. I tested it today, and confirmed that
it's a regression bug. I also confirmed that there's no regression bug in
showuon commented on a change in pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#discussion_r667474248
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupsHandler.java
##
@@ -112,21 +112,34 @@ private void
showuon commented on a change in pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#discussion_r667474183
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandler.java
##
@@ -104,15 +104,18 @@ public
showuon commented on pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#issuecomment-877791048
@dajac , thanks for letting me know. I tested it today, and confirmed that
it's a regression bug. I also confirmed that there's no regression bug in
jacky1193610322 commented on pull request #9624:
URL: https://github.com/apache/kafka/pull/9624#issuecomment-877790095
Should this be included in AK3.0？
--
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
dajac commented on pull request #11016:
URL: https://github.com/apache/kafka/pull/11016#issuecomment-81635
I am reviewing the other handlers which have been introduced in KIP-699. I
will follow-up with other PRs if necessary.
--
This is an automated message from the Apache Git
dajac commented on a change in pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#discussion_r667453896
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java
##
@@ -136,21 +142,28 @@ private void
David Jacot created KAFKA-13058:
---
Summary: `AlterConsumerGroupOffsetsHandler` does not handle
partition errors correctly.
Key: KAFKA-13058
URL: https://issues.apache.org/jira/browse/KAFKA-13058
wycc commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r667443055
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -61,18 +59,18 @@
import
wycc commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r667443023
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -96,13 +94,7 @@
import static
wycc commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r667442355
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -939,6 +939,11 @@ private StreamThread
wycc commented on a change in pull request #11017:
URL: https://github.com/apache/kafka/pull/11017#discussion_r667442158
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -246,10 +246,15 @@ State setState(final State
[
https://issues.apache.org/jira/browse/KAFKA-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Kashavkin updated KAFKA-13055:
-
Description:
I'm setting up kafka security with multiple listeners. Listener for broker
satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r667427888
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java
##
@@ -0,0 +1,432 @@
+/*
45 matches
Mail list logo
