[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved KAFKA-10889.
--
Resolution: Not A Bug
I am closing the issue as not a bug because the brokers were working as
[
https://issues.apache.org/jira/browse/KAFKA-10822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10822:
---
Summary: Force some stdout from system tests for Travis (was: Force some
stdout from
showuon commented on pull request #9775:
URL: https://github.com/apache/kafka/pull/9775#issuecomment-752313583
Monitoring recent test failed: I think reduce the records to 450 should be
good enough. How do you think? @chia7712
```
org.scalatest.exceptions.TestFailedException: Timed
[
https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256233#comment-17256233
]
dengziming commented on KAFKA-10694:
SendBuilder is the best choice, we can add a method such as
[
https://issues.apache.org/jira/browse/KAFKA-10876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10876:
--
Description:
If a Connect worker tries to start a connector or task that it is already
jolshan commented on pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#issuecomment-752276710
Updated to match invariants discussed above, still need to look at a few
other areas like producer snapshots and high watermark
hachikuji merged pull request #9781:
URL: https://github.com/apache/kafka/pull/9781
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
[
https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256168#comment-17256168
]
Pawel Ryznar commented on KAFKA-4090:
-
Had the same issue. Spring Boot 2.3.7 (Reactor Kafka, Kafka
mjsax commented on pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#issuecomment-752241886
To make the build pass, for now, it should be sufficient to just deprecate
the method via `@nowarn("cat=deprecation")` -- But it seems we should update
the Scala API, too. If you
[
https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10892:
Issue Type: New Feature (was: Improvement)
> Add Topology#connectSourceStoreAndTopic as
[
https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10892:
Affects Version/s: (was: 2.7.0)
> Add Topology#connectSourceStoreAndTopic as a public
[
https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10892:
Labels: need-kip (was: )
> Add Topology#connectSourceStoreAndTopic as a public method
>
hachikuji commented on pull request #9781:
URL: https://github.com/apache/kafka/pull/9781#issuecomment-752188121
@chia7712 Since this is a new api, I think we are free to choose its error
semantics. I agree that there is some inconsistency between different APIs, but
we are often stuck
[
https://issues.apache.org/jira/browse/KAFKA-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256052#comment-17256052
]
Wenbing Shen commented on KAFKA-10891:
--
[~junrao] Can you take a look at this PR?Thank you very
[
https://issues.apache.org/jira/browse/KAFKA-10822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10822:
---
Summary: Force some stdout from
downgrade_test.py/upgrade_test.py/replication_test.py for
chia7712 opened a new pull request #9796:
URL: https://github.com/apache/kafka/pull/9796
issue: https://issues.apache.org/jira/browse/KAFKA-10498
Currently the consumer has logic to detect truncations (as a result of
unclean leader election for example) using the
inponomarev commented on pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#issuecomment-752098770
> Can you also update the docs for Kafka Streams and the 2.8 upgrade guide
in this PR.
The documentation had been already updated (see changes in
inponomarev commented on a change in pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#discussion_r549722543
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/BranchedInternal.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255980#comment-17255980
]
Wenbing Shen commented on KAFKA-10889:
--
[~becket_qin] Thank you for your guidance.
> The log
Tomohiro Hashidate created KAFKA-10892:
--
Summary: Add Topology#connectSourceStoreAndTopic as a public method
Key: KAFKA-10892
URL: https://issues.apache.org/jira/browse/KAFKA-10892
Project: Kafka
keashem closed pull request #9795:
URL: https://github.com/apache/kafka/pull/9795
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
keashem opened a new pull request #9795:
URL: https://github.com/apache/kafka/pull/9795
*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 of testing
martin-g commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-752043902
I've created https://github.com/apache/kafka/pull/9794. It applies the
changes from this PR and also fixes the issue in the comment above.
It also adds an extra job for
martin-g opened a new pull request #9794:
URL: https://github.com/apache/kafka/pull/9794
More and more software development is being done on ARM64 CPU architecture.
It would be good if Apache Kafka is being regularly tested on ARM64.
Changes:
* apply the changes from
[
https://issues.apache.org/jira/browse/KAFKA-10890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
GeoffreyStark updated KAFKA-10890:
--
Attachment: server.properties
> Broker just stated Ignoring LeaderAndIsr request from
[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255919#comment-17255919
]
Jiangjie Qin commented on KAFKA-10889:
--
[~wenbing.shen] You can achieve this by setting the
cshuig closed pull request #9793:
URL: https://github.com/apache/kafka/pull/9793
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
cshuig commented on pull request #9793:
URL: https://github.com/apache/kafka/pull/9793#issuecomment-752025143
同步2.7
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
cshuig opened a new pull request #9793:
URL: https://github.com/apache/kafka/pull/9793
*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 of testing
[
https://issues.apache.org/jira/browse/KAFKA-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255911#comment-17255911
]
Wenbing Shen commented on KAFKA-10891:
--
[~showuon] I added validation of control requests in PR,
wenbingshen commented on pull request #9789:
URL: https://github.com/apache/kafka/pull/9789#issuecomment-752019739
@showuon Hello,I made some changes and added a test case.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-10890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255910#comment-17255910
]
GeoffreyStark commented on KAFKA-10890:
---
In the log on this node that has just been restarted, it
[
https://issues.apache.org/jira/browse/KAFKA-10890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
GeoffreyStark updated KAFKA-10890:
--
Attachment: image-2020-12-29-18-00-22-344.png
> Broker just stated Ignoring LeaderAndIsr
[
https://issues.apache.org/jira/browse/KAFKA-10890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255909#comment-17255909
]
GeoffreyStark commented on KAFKA-10890:
---
!image-2020-12-29-18-00-22-344.png!
> Broker just
wenbingshen closed pull request #9789:
URL: https://github.com/apache/kafka/pull/9789
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
Wenbing Shen created KAFKA-10891:
Summary: The control plane needs to force the validation of
requests from the controller
Key: KAFKA-10891
URL: https://issues.apache.org/jira/browse/KAFKA-10891
g1geordie commented on a change in pull request #9778:
URL: https://github.com/apache/kafka/pull/9778#discussion_r549631973
##
File path: core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala
##
@@ -212,7 +214,9 @@ class ClientQuotasRequestTest extends
martin-g commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-751998685
I've tested this PR on my ARM64 machine and at
[TravisCI](https://travis-ci.com/github/martin-g/kafka/jobs/465480469). At both
environments it fails with:
```
...
38 matches
Mail list logo
