[
https://issues.apache.org/jira/browse/KAFKA-12158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming reassigned KAFKA-12158:
--
Assignee: dengziming
> Consider better return type of RaftClient.scheduleAppend
>
[
https://issues.apache.org/jira/browse/KAFKA-12908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366100#comment-17366100
]
dengziming edited comment on KAFKA-12908 at 6/20/21, 4:30 AM:
--
This may
[
https://issues.apache.org/jira/browse/KAFKA-12908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366100#comment-17366100
]
dengziming commented on KAFKA-12908:
This may be depend on KAFKA-12155
> Load snapshot heuristic
>
kpatelatwork commented on pull request #10822:
URL: https://github.com/apache/kafka/pull/10822#issuecomment-864493282
Fired up local kafka server and kafka connect and was able to curl the API
locally.
> ➜ kafka git:(KAFKA-4793) ✗ curl
showuon commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r654866143
##
File path: clients/src/main/java/org/apache/kafka/common/requests/ApiError.java
##
@@ -36,10 +37,16 @@
private final String message;
[
https://issues.apache.org/jira/browse/KAFKA-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366024#comment-17366024
]
Guozhang Wang commented on KAFKA-12889:
---
Thanks [~iamgd67] for reporting the issue and for the fix
guozhangwang merged pull request #10818:
URL: https://github.com/apache/kafka/pull/10818
--
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 service,
guozhangwang commented on pull request #10818:
URL: https://github.com/apache/kafka/pull/10818#issuecomment-864471492
@iamgd67 Thanks for the PR! and also thank @showuon for the reviews. I made
a quick pass and it LGTM. Merging to trunk now.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/KAFKA-12971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366015#comment-17366015
]
Ismael Juma commented on KAFKA-12971:
-
Thanks for the report. 1.1.1 is no longer supported. Any
[
https://issues.apache.org/jira/browse/KAFKA-12971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366011#comment-17366011
]
GEORGE LI commented on KAFKA-12971:
---
This issue is fixed in the {{1.1.x}} kafka client by back porting
GEORGE LI created KAFKA-12971:
-
Summary: Kakfa 1.1.x clients cache broker hostnames, client stuck
when host is swapped for the same broker.id
Key: KAFKA-12971
URL: https://issues.apache.org/jira/browse/KAFKA-12971
guozhangwang commented on pull request #10869:
URL: https://github.com/apache/kafka/pull/10869#issuecomment-864424835
@vvcephei I took a quick look at the more recent commits (for `KStream.java`
the part you wanted me to take another look is around the javadoc copy-paste
errors, right?),
chia7712 merged pull request #10905:
URL: https://github.com/apache/kafka/pull/10905
--
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 service,
chia7712 merged pull request #10908:
URL: https://github.com/apache/kafka/pull/10908
--
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 service,
[
https://issues.apache.org/jira/browse/KAFKA-12908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming reassigned KAFKA-12908:
--
Assignee: dengziming
> Load snapshot heuristic
> ---
>
>
chia7712 opened a new pull request #10908:
URL: https://github.com/apache/kafka/pull/10908
The broker id starts with 1
(https://github.com/apache/kafka/blob/trunk/tests/kafkatest/services/kafka/kafka.py#L207)
so `round_trip_fault_test.py` do assign replica to nonexistent broker.
[
https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12243:
--
Assignee: loboxu
> Add toString methods to some of the classes introduced by this Epic
>
[
https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12243:
--
Assignee: (was: loboxu)
> Add toString methods to some of the classes introduced by this Epic
>
[
https://issues.apache.org/jira/browse/KAFKA-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12333:
--
Assignee: (was: loboxu)
> KafkaMetadataLog and MockLock should validate that appended epochs are
[
https://issues.apache.org/jira/browse/KAFKA-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12851:
--
Assignee: (was: loboxu)
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu updated KAFKA-10900:
---
Comment: was deleted
(was: [~jagsancio] Can you give me some guidance? Where the metrics are added
in the
[
https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365914#comment-17365914
]
loboxu commented on KAFKA-12689:
Thank you very much for reminding me. I know what I should do.
>
vamossagar12 commented on pull request #10877:
URL: https://github.com/apache/kafka/pull/10877#issuecomment-864382529
@mjsax , have added the tests for the combinations that you have mentioned.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
C0urante commented on pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#issuecomment-864380630
@gharris1727 you've been tremendously helpful so far in the design process;
if you have time would you like to take a look at the implementation as well?
--
This is an
C0urante opened a new pull request #10907:
URL: https://github.com/apache/kafka/pull/10907
Implements
[KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors#KIP618:ExactlyOnceSupportforSourceConnectors-Newmetrics).
There are
showuon commented on pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#issuecomment-864374754
@hachikuji , I checked and there's no race condition there. The reason why
we didn't put `NOT_CONTROLLER` in EnvelopResponse itself is because we will
build envelopeResponse
showuon commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r654763984
##
File path: core/src/main/scala/kafka/network/RequestChannel.scala
##
@@ -124,8 +124,15 @@ object RequestChannel extends Logging {
def
27 matches
Mail list logo
