[
https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324391#comment-17324391
]
Aviral Srivastava commented on KAFKA-12506:
---
Hi [~ableegoldman], upon running the command:
wenbingshen commented on pull request #10553:
URL: https://github.com/apache/kafka/pull/10553#issuecomment-821914238
@dajac Can you take a look at this PR? Thanks. :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
wenbingshen commented on pull request #10553:
URL: https://github.com/apache/kafka/pull/10553#issuecomment-821913990
@lbradstreet Can you take a look at this PR? I think you made a mistake by
accident. :)
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324378#comment-17324378
]
Luke Chen commented on KAFKA-12675:
---
Awesome! I'll also check your code to see how we can improve in
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r615204809
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataContext.java
##
@@ -0,0 +1,83 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/KAFKA-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-9119.
-
Fix Version/s: 2.8.0
Resolution: Done
> KIP-500: Replace ZooKeeper with a Metadata Quorum
[
https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324370#comment-17324370
]
Colin McCabe commented on KAFKA-9705:
-
[~vvcephei]: this isn't a blocker for 2.8, but we will have to
[
https://issues.apache.org/jira/browse/KAFKA-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-9125.
-
Fix Version/s: 2.8.0
Assignee: Ron Dagostino (was: Viktor Somogyi-Vass)
[
https://issues.apache.org/jira/browse/KAFKA-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324369#comment-17324369
]
Colin McCabe commented on KAFKA-9125:
-
We do indeed now get GroupMetadataManager and
[
https://issues.apache.org/jira/browse/KAFKA-10691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-10691:
-
Labels: kip-500 (was: )
> AlterIsr Respond with wrong Error Id
>
[
https://issues.apache.org/jira/browse/KAFKA-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-8820:
Labels: kip-500 (was: )
> kafka-reassign-partitions.sh should support the KIP-455 API
>
[
https://issues.apache.org/jira/browse/KAFKA-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9119:
Labels: kip-500 (was: )
> KIP-500: Replace ZooKeeper with a Metadata Quorum
>
[
https://issues.apache.org/jira/browse/KAFKA-9167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9167:
Labels: kip-500 (was: )
> Implement a broker to controller request channel
>
[
https://issues.apache.org/jira/browse/KAFKA-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9154:
Labels: kip-500 (was: )
> ProducerId generation should be managed by the Controller
>
[
https://issues.apache.org/jira/browse/KAFKA-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9166:
Labels: kip-500 (was: )
> Implement MetadataFetch API
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9154:
Parent: (was: KAFKA-9119)
Issue Type: New Feature (was: Sub-task)
> ProducerId
[
https://issues.apache.org/jira/browse/KAFKA-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324367#comment-17324367
]
Colin McCabe commented on KAFKA-9154:
-
[~satish.duggana]: [~mumrah] posted a KIP about this, KIP-730.
[
https://issues.apache.org/jira/browse/KAFKA-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-9154:
---
Assignee: David Arthur (was: Colin McCabe)
> ProducerId generation should be managed by
[
https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9837:
Parent: (was: KAFKA-9119)
Issue Type: New Feature (was: Sub-task)
> New RPC for
[
https://issues.apache.org/jira/browse/KAFKA-9837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9837:
Labels: kip-500 (was: )
> New RPC for notifying controller of failed replica
>
kpatelatwork commented on a change in pull request #10549:
URL: https://github.com/apache/kafka/pull/10549#discussion_r615310932
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java
##
@@ -187,17 +192,24 @@ private
[
https://issues.apache.org/jira/browse/KAFKA-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-9166.
-
Fix Version/s: 2.8.0
Resolution: Duplicate
Closing as duplicate of KAFKA-10435
>
[
https://issues.apache.org/jira/browse/KAFKA-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-9118:
Parent: (was: KAFKA-9119)
Issue Type: Improvement (was: Sub-task)
>
[
https://issues.apache.org/jira/browse/KAFKA-9167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324359#comment-17324359
]
Colin McCabe commented on KAFKA-9167:
-
Closing as duplicate of KAFKA-10270
> Implement a broker to
[
https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-9124.
-
Fix Version/s: 2.7.0
Resolution: Fixed
> KIP-497: ISR changes should be propagated via
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324358#comment-17324358
]
Travis Bischel commented on KAFKA-12675:
Great insight on getting rid of
[
https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324357#comment-17324357
]
Colin McCabe commented on KAFKA-9124:
-
[~mumrah] implemented this here:
[
https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-9124:
---
Assignee: David Arthur (was: Colin McCabe)
> KIP-497: ISR changes should be propagated via
[
https://issues.apache.org/jira/browse/KAFKA-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324356#comment-17324356
]
Colin McCabe commented on KAFKA-9119:
-
The upcoming Kafka 2.8 release now supports running in KRaft
[
https://issues.apache.org/jira/browse/KAFKA-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12345.
--
Fix Version/s: 2.8.0
Assignee: Boyang Chen
Resolution: Fixed
> KIP-500:
[
https://issues.apache.org/jira/browse/KAFKA-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-12349:
Assignee: Jason Gustafson (was: Colin McCabe)
> Follow up on PartitionEpoch in KIP-500
[
https://issues.apache.org/jira/browse/KAFKA-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324355#comment-17324355
]
Colin McCabe commented on KAFKA-12349:
--
[~hachikuji] has a PR for removing the compatibility shim
[
https://issues.apache.org/jira/browse/KAFKA-12276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12276.
--
Fix Version/s: 2.8.0
Resolution: Fixed
> Add KIP-500 controller code
>
[
https://issues.apache.org/jira/browse/KAFKA-12282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-12282.
--
Fix Version/s: 2.8.0
Resolution: Fixed
> KIP-500: Reconcile configuration variables
kebab-mai-haddi opened a new pull request #10554:
URL: https://github.com/apache/kafka/pull/10554
*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
kebab-mai-haddi closed pull request #10432:
URL: https://github.com/apache/kafka/pull/10432
--
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.
For queries about this
Wenbing Shen created KAFKA-12680:
Summary: Failed to restart the broker in kraft mode
Key: KAFKA-12680
URL: https://issues.apache.org/jira/browse/KAFKA-12680
Project: Kafka
Issue Type: Bug
wenbingshen opened a new pull request #10553:
URL: https://github.com/apache/kafka/pull/10553
When I tested the kraft mode, I found that the time taken to load the
snapshot in the startup log was negative.
[2021-04-18 00:19:37,377] INFO [Log partition=@metadata-0,
dejan2609 commented on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821841765
Ok, I finished my writings above (I just had to be as detailed as possible,
these comments serve me a lot).
> Could we reintroduce a configuration that behaves the same
dejan2609 commented on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821841078
So, I started to abandon quick and dirty solution and to lean towards
something heavier (i.e. to a some form of refactoring):
-
ijuma edited a comment on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821839178
Could we reintroduce a configuration that behaves the same as `testRuntime`
did before it was removed?
--
This is an automated message from the Apache Git Service.
To
ijuma commented on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821839178
Could we reintroduce a configuration that behaved the same as `testRuntime`?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
dejan2609 edited a comment on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821837798
Digging through project history I managed to find some commits that are
seems to be related (see the comment):
```
project(':streams') {
dependencies {
dejan2609 edited a comment on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821837798
Digging through project history I managed to find some commits that are
seems to be related (see the comment):
```
project(':streams') {
dependencies {
dejan2609 commented on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821837798
Digging through project history I managed to find some commits that are
seems to be related (see the comment):
```
project(':streams') {
dependencies {
[
https://issues.apache.org/jira/browse/KAFKA-12660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming reassigned KAFKA-12660:
--
Assignee: dengziming
> Do not update offset commit sensor after append failure
>
[
https://issues.apache.org/jira/browse/KAFKA-10783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming resolved KAFKA-10783.
Resolution: Won't Do
> Rewrite TopicPartitionStateZNode struct with auto-generated protocol
>
dejan2609 commented on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821831500
Also, after some digging I stumbled upon these GitHub resources (I will
intentionally leave them formatted as code):
- `https://github.com/gradle/gradle/issues/6353`
-
dejan2609 commented on pull request #10466:
URL: https://github.com/apache/kafka/pull/10466#issuecomment-821826801
I am going to split my findings to a separate comments... here it goes.
I decided to work with Gradle 6.8.3 for the moment (that is, until circular
dependency issue is
ketulgupta1995 commented on pull request #10519:
URL: https://github.com/apache/kafka/pull/10519#issuecomment-821793666
Hi @lct45 removed the nits and checkstyle issues.
Please review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324204#comment-17324204
]
Luke Chen commented on KAFKA-12675:
---
PR: [https://github.com/apache/kafka/pull/10552]
[~twmb], I
showuon commented on pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#issuecomment-821792471
@ableegoldman , please help review this PR. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
wenbingshen commented on a change in pull request #10551:
URL: https://github.com/apache/kafka/pull/10551#discussion_r615229878
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
##
@@ -736,7 +735,6 @@ class
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r615229673
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
##
@@ -453,6 +453,43 @@ public void
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r615229332
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -527,12 +615,23 @@ private int
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r615229332
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -527,12 +615,23 @@ private int
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r615229166
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -387,58 +398,121 @@ private boolean
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r615228815
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -362,23 +360,36 @@ private boolean
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r615228600
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -387,58 +398,121 @@ private boolean
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r615227866
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -313,26 +312,24 @@ private boolean
showuon opened a new pull request #10552:
URL: https://github.com/apache/kafka/pull/10552
I did code refactor, keep the same algorithm in this PR.
I've achieved:
1. Originally, With this setting:
```
topicCount = 50;
partitionCount = 800;
consumerCount = 800;
```
We
chia7712 commented on a change in pull request #10551:
URL: https://github.com/apache/kafka/pull/10551#discussion_r615220275
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
##
@@ -736,7 +735,6 @@ class TopicCommandWithAdminClientTest
feyman2016 commented on pull request #10377:
URL: https://github.com/apache/kafka/pull/10377#issuecomment-821774667
Hi, I checked locally, all the failed tests should be unrelated:
```
Build / JDK 8 and Scala 2.12 /
63 matches
Mail list logo
