[
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 downgr
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 o
[
https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256233#comment-17256233
]
dengziming commented on KAFKA-10694:
SendBuilder is the best choice, we can add a me
[
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
runnin
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&focusedCommentId=17256168#comment-17256168
]
Pawel Ryznar commented on KAFKA-4090:
-
Had the same issue. Spring Boot 2.3.7 (Reactor
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 ca
[
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 a
[
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 wit
[
https://issues.apache.org/jira/browse/KAFKA-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256052#comment-17256052
]
Wenbing Shen commented on KAFKA-10891:
--
[~junrao] Can you take a look at this PR?Th
[
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 Tr
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 OffsetsForLeaderEpoc
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
`docs/streams/develope
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 Apache
[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255980#comment-17255980
]
Wenbing Shen commented on KAFKA-10889:
--
[~becket_qin] Thank you for your guidance.
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 th
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 s
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 Travis
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:/
[
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 control
[
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255919#comment-17255919
]
Jiangjie Qin commented on KAFKA-10889:
--
[~wenbing.shen] You can achieve this by set
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 the
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 st
[
https://issues.apache.org/jira/browse/KAFKA-10891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255911#comment-17255911
]
Wenbing Shen commented on KAFKA-10891:
--
[~showuon] I added validation of control r
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 Ser
[
https://issues.apache.org/jira/browse/KAFKA-10890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255910#comment-17255910
]
GeoffreyStark commented on KAFKA-10890:
---
In the log on this node that has just bee
[
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 requ
[
https://issues.apache.org/jira/browse/KAFKA-10890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255909#comment-17255909
]
GeoffreyStark commented on KAFKA-10890:
---
!image-2020-12-29-18-00-22-344.png!
> B
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 t
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
Proje
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 BaseRequest
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:
```
...
Co
38 matches
Mail list logo