wushujames commented on pull request #8225:
URL: https://github.com/apache/kafka/pull/8225#issuecomment-640413681
@hachikuji , there is a KIP for this.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-579%3A+new+exception+on+min.insync.replicas+%3E+replication.factor
And yes, th
stanislavkozlovski closed pull request #7181:
URL: https://github.com/apache/kafka/pull/7181
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 a change in pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#discussion_r436519796
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -580,53 +586,105 @@ class LogManager(logDirs: Seq[File],
* to avoid exposing data that
dajac commented on a change in pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#discussion_r436523916
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -878,8 +936,7 @@ class LogManager(logDirs: Seq[File],
// Now that replica in sourc
[
https://issues.apache.org/jira/browse/KAFKA-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128007#comment-17128007
]
James Cheng commented on KAFKA-9935:
Is this related to https://issues.apache.org/jir
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128005#comment-17128005
]
James Cheng commented on KAFKA-10105:
-
Is this related to https://issues.apache.org/
dajac commented on a change in pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#discussion_r436532135
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -324,8 +324,17 @@ class ReplicaManager(val config: KafkaConfig,
brokerTopicSt
viktorsomogyi commented on pull request #5620:
URL: https://github.com/apache/kafka/pull/5620#issuecomment-640488676
@cmccabe just checking back, please let me know if you can set aside some
time to review this.
This is an a
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128144#comment-17128144
]
Karthik commented on KAFKA-7500:
Hi All, Im unable to find a document for MM2, Any leads
kowshik commented on a change in pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#discussion_r436493426
##
File path: core/src/main/scala/kafka/cluster/Broker.scala
##
@@ -34,14 +36,21 @@ object Broker {
brokerId: Int,
kowshik commented on a change in pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#discussion_r436607402
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -442,6 +445,8 @@ object KafkaConfig {
val ControlledShutdownMaxRetriesProp = "cont
stanislavkozlovski closed pull request #7181:
URL: https://github.com/apache/kafka/pull/7181
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
ijuma commented on a change in pull request #8802:
URL: https://github.com/apache/kafka/pull/8802#discussion_r436325309
##
File path: clients/src/main/resources/common/message/FetchRequest.json
##
@@ -49,7 +49,7 @@
"fields": [
{ "name": "ReplicaId", "type": "int32", "ve
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128301#comment-17128301
]
Luiz Ferraz commented on KAFKA-7870:
We just got a similar error on Kafka Streams
[20
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128301#comment-17128301
]
Luiz Ferraz edited comment on KAFKA-7870 at 6/8/20, 1:27 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128366#comment-17128366
]
feyman commented on KAFKA-9377:
---
[~bchen225242] Created a PR [https://github.com/apache/kaf
Bruno Cadonna created KAFKA-10119:
-
Summary: StreamsResetter fails with TimeoutException for older
Brokers
Key: KAFKA-10119
URL: https://issues.apache.org/jira/browse/KAFKA-10119
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128389#comment-17128389
]
John Roesler commented on KAFKA-9891:
-
Hi [~mjsax] and [~bchen225242] ,
I see you're
Tom Bentley created KAFKA-10120:
---
Summary: DescribeLogDirsResult exposes internal classes
Key: KAFKA-10120
URL: https://issues.apache.org/jira/browse/KAFKA-10120
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8372:
---
Fix Version/s: 3.0.0
> Remove deprecated RocksDB#compactRange API
> -
[
https://issues.apache.org/jira/browse/KAFKA-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8372:
---
Affects Version/s: (was: 3.0.0)
> Remove deprecated RocksDB#compactRange API
> --
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10017:
Fix Version/s: 2.6.0
> Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaT
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128438#comment-17128438
]
Itamar Benjamin commented on KAFKA-10114:
-
Hi,
Our app calls flush() before clo
John Roesler created KAFKA-10121:
Summary: Streams Task Assignment optimization design
Key: KAFKA-10121
URL: https://issues.apache.org/jira/browse/KAFKA-10121
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10121:
-
Description:
Beginning in Kafka 2.6.0, Streams has a new task assignment algorithm that
reacts
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128492#comment-17128492
]
Chris Egerton commented on KAFKA-9216:
--
Based on [this
change|https://github.com/ap
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128492#comment-17128492
]
Chris Egerton edited comment on KAFKA-9216 at 6/8/20, 5:51 PM:
[
https://issues.apache.org/jira/browse/KAFKA-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-9991:
Assignee: Guozhang Wang
> Flaky Test
> KTableSourceTopicRestartIntegrationTest.shouldRest
[
https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9381:
--
Assignee: Randall Hauch (was: David Arthur)
> kafka-streams-scala: Javadocs + Scalado
[
https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128499#comment-17128499
]
Matthias J. Sax commented on KAFKA-9381:
[~rhauch] – can you maybe help us resolv
[
https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10119:
--
Priority: Blocker (was: Major)
> StreamsResetter fails with TimeoutException for older Broker
[
https://issues.apache.org/jira/browse/KAFKA-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10077:
-
Issue Type: Improvement (was: Bug)
> Filter downstream of state-store results in suprious tombs
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128529#comment-17128529
]
Ismael Juma commented on KAFKA-10114:
-
I believe there's a KIP for a flush with a ti
[
https://issues.apache.org/jira/browse/KAFKA-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10106.
-
Fix Version/s: 2.7.0
Assignee: NIKHIL
Resolution: Fixed
Merged the PR to trunk.
> log t
[
https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128608#comment-17128608
]
John Roesler commented on KAFKA-10119:
--
Thanks for marking this as a blocker, it se
[
https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10119:
Fix Version/s: 2.6.0
> StreamsResetter fails with TimeoutException for older Brokers
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128646#comment-17128646
]
Matthias J. Sax commented on KAFKA-9891:
I am not 100% sure. But even if not, it
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127772#comment-17127772
]
Matthias J. Sax edited comment on KAFKA-6435 at 6/8/20, 8:57 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128651#comment-17128651
]
Matthias J. Sax commented on KAFKA-6435:
I would fine with adding `--internal-top
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128656#comment-17128656
]
Boyang Chen commented on KAFKA-6435:
Thanks for confirming! [~JoelWee] Do you think o
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128662#comment-17128662
]
Guozhang Wang commented on KAFKA-8803:
--
[~rocketraman] Have you seen it again since
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-8803.
--
Resolution: Fixed
> Stream will not start due to TimeoutException: Timeout expired after
> 600
[
https://issues.apache.org/jira/browse/KAFKA-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10005.
---
Fix Version/s: 2.6.0
Assignee: Guozhang Wang
Resolution: Fixed
> Decouple Re
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128669#comment-17128669
]
Joel Wee commented on KAFKA-6435:
-
Thanks all for the input, and thanks for pushing this
[
https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-7608.
Resolution: Fixed
KIP-221 is merged. Closing this ticket.
> A Kafka Streams DSL transform
[
https://issues.apache.org/jira/browse/KAFKA-10063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10063.
-
Fix Version/s: 2.6.0
Resolution: Fixed
> UnsupportedOperation when querying clean
Guozhang Wang created KAFKA-10122:
-
Summary: Consumer should allow heartbeat during rebalance as well
Key: KAFKA-10122
URL: https://issues.apache.org/jira/browse/KAFKA-10122
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-10122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128763#comment-17128763
]
John Roesler commented on KAFKA-10122:
--
Thanks, Guozhang! I feel like this was my o
[
https://issues.apache.org/jira/browse/KAFKA-9887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michael Carter reassigned KAFKA-9887:
-
Assignee: Michael Carter
> failed-task-count JMX metric not updated if task fails during
[
https://issues.apache.org/jira/browse/KAFKA-9887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128873#comment-17128873
]
Michael Carter commented on KAFKA-9887:
---
I'm going to have a go at fixing this one
[
https://issues.apache.org/jira/browse/KAFKA-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128874#comment-17128874
]
Ruslan Dautkhanov commented on KAFKA-3834:
--
That's great this issue is fixed on
Jason Gustafson created KAFKA-10123:
---
Summary: Regression resetting offsets in consumer when fetching
from old broker
Key: KAFKA-10123
URL: https://issues.apache.org/jira/browse/KAFKA-10123
Project:
[
https://issues.apache.org/jira/browse/KAFKA-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10123:
Description:
We saw this error in system tests:
{code}
java.lang.NullPointerException
[
https://issues.apache.org/jira/browse/KAFKA-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10123:
Description:
We saw this error in system tests:
{code}
java.lang.NullPointerException
jiamei xie created KAFKA-10124:
--
Summary: ConsumerPerformance output wrong rebalance.time.ms
Key: KAFKA-10124
URL: https://issues.apache.org/jira/browse/KAFKA-10124
Project: Kafka
Issue Type:
Chia-Ping Tsai created KAFKA-10125:
--
Summary: The partition which is removing should be considered to
be under reassignment
Key: KAFKA-10125
URL: https://issues.apache.org/jira/browse/KAFKA-10125
Pro
56 matches
Mail list logo
