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
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:
[
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
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-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
[
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-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
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-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
[
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-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-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-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-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-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-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=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-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-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-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-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-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-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-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-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-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-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-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-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
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-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
[
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-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
> --
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-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
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-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
[
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-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
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
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
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,
[
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
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
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
[
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/
[
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
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
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
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
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
56 matches
Mail list logo