[
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
[
https://issues.apache.org/jira/browse/KAFKA-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128874#comment-17128874
]
Ruslan Dautkhanov commented on KAFKA-3834:
--
That's great this issue is fixed on the discovery
[
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
[
https://issues.apache.org/jira/browse/KAFKA-9887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=17128763#comment-17128763
]
John Roesler commented on KAFKA-10122:
--
Thanks, Guozhang! I feel like this was my oversight when I
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
[
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
[
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=17128669#comment-17128669
]
Joel Wee commented on KAFKA-6435:
-
Thanks all for the input, and thanks for pushing this along
[
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
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128662#comment-17128662
]
Guozhang Wang commented on KAFKA-8803:
--
[~rocketraman] Have you seen it again since then?
> Stream
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128656#comment-17128656
]
Boyang Chen commented on KAFKA-6435:
Thanks for confirming! [~JoelWee] Do you think our discussion
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128651#comment-17128651
]
Matthias J. Sax commented on KAFKA-6435:
I would fine with adding `--internal-topics` flag.
>
[
https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127772#comment-17127772
]
Matthias J. Sax edited comment on KAFKA-6435 at 6/8/20, 8:57 PM:
-
I don't
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128646#comment-17128646
]
Matthias J. Sax commented on KAFKA-9891:
I am not 100% sure. But even if not, it might be severe
[
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=17128608#comment-17128608
]
John Roesler commented on KAFKA-10119:
--
Thanks for marking this as a blocker, it seems like a
[
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
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128529#comment-17128529
]
Ismael Juma commented on KAFKA-10114:
-
I believe there's a KIP for a flush with a timeout. Still, it
[
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128499#comment-17128499
]
Matthias J. Sax commented on KAFKA-9381:
[~rhauch] – can you maybe help us resolving this issue
[
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 +
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128492#comment-17128492
]
Chris Egerton commented on KAFKA-9216:
--
Based on [this
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128492#comment-17128492
]
Chris Egerton edited comment on KAFKA-9216 at 6/8/20, 5:51 PM:
---
Based on
[
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=17128438#comment-17128438
]
Itamar Benjamin commented on KAFKA-10114:
-
Hi,
Our app calls flush() before closing the
[
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
[
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=17128389#comment-17128389
]
John Roesler commented on KAFKA-9891:
-
Hi [~mjsax] and [~bchen225242] ,
I see you're just added this
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=17128366#comment-17128366
]
feyman commented on KAFKA-9377:
---
[~bchen225242] Created a PR [https://github.com/apache/kafka/pull/8832]
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128301#comment-17128301
]
Luiz Ferraz edited comment on KAFKA-7870 at 6/8/20, 1:27 PM:
-
We just got a
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128301#comment-17128301
]
Luiz Ferraz commented on KAFKA-7870:
We just got a similar error on Kafka Streams
[2020-06-08
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",
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 =
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:
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128144#comment-17128144
]
Karthik commented on KAFKA-7500:
Hi All, Im unable to find a document for MM2, Any leads to the
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
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,
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128005#comment-17128005
]
James Cheng commented on KAFKA-10105:
-
Is this related to
[
https://issues.apache.org/jira/browse/KAFKA-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128007#comment-17128007
]
James Cheng commented on KAFKA-9935:
Is this related to
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
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,
chia7712 edited a comment on pull request #8660:
URL: https://github.com/apache/kafka/pull/8660#issuecomment-640407047
most doc errors are fixed by e385e4639ea1bcf53af4f11ded10c77290dca8ee,
b020671f3124e7fea464a6f5e6712c1e773441c5 and
31c81a6e9e7703cd86a3fc59a317205c8c57edc3. This PR
chia7712 commented on pull request #8660:
URL: https://github.com/apache/kafka/pull/8660#issuecomment-640407047
most doc errors are fixed by e385e4639ea1bcf53af4f11ded10c77290dca8ee. This
PR fixes the remaining errors :)
showuon commented on pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#issuecomment-640396593
Thanks @abbccdda , I've address your review comments in this commit:
https://github.com/apache/kafka/pull/8712/commits/0567ecbc82c01b0c6e596fe5c28918f3b530a263.
Thank you.
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r436479515
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -59,6 +59,9 @@ private
58 matches
Mail list logo
