[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397429#comment-16397429
]
ASF GitHub Bot commented on KAFKA-6647:
---
tedyu opened a new pull request #4702: KAFKA-6647
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397437#comment-16397437
]
George Bloggs commented on KAFKA-6647:
--
Hi. It does remove the lock file in the finally block but
[
https://issues.apache.org/jira/browse/KAFKA-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6617:
Summary: Improve controller performance by batching reassignment znode
write operation (was: KAFKA-6617;
[
https://issues.apache.org/jira/browse/KAFKA-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-6617:
Summary: KAFKA-6617; Improve controller performance by batching
reassignment znode write operation (was:
[
https://issues.apache.org/jira/browse/KAFKA-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-6643:
-
Description:
In the current scenario, Kafka Streams has changelog Kafka topics(internal
topics
[
https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396592#comment-16396592
]
ASF GitHub Bot commented on KAFKA-6024:
---
hachikuji closed pull request #4617: KAFKA-6024 Move
[
https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-6024.
Resolution: Fixed
Fix Version/s: 1.2.0
> Consider moving validation in KafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huxihx reassigned KAFKA-6637:
-
Assignee: huxihx
> if set topic config segment.ms=0 Kafka broker won't be able to start
>
[
https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396593#comment-16396593
]
Matthias J. Sax commented on KAFKA-6555:
Thanks [~asurana]! Looking forward to your KIP!
> Making
[
https://issues.apache.org/jira/browse/KAFKA-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396622#comment-16396622
]
ASF GitHub Bot commented on KAFKA-6637:
---
huxihx closed pull request #4697: KAFKA-6637: Avoid divide
[
https://issues.apache.org/jira/browse/KAFKA-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396711#comment-16396711
]
ASF GitHub Bot commented on KAFKA-6637:
---
huxihx opened a new pull request #4698: KAFKA-6637: Avoid
[
https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Khaireddine Rezgui reassigned KAFKA-6535:
-
Assignee: Khaireddine Rezgui
> Set default retention ms for Streams repartition
[
https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396694#comment-16396694
]
Rajini Sivaram commented on KAFKA-6195:
---
Looks good to me, I will respond on the discuss thread.
>
Mike Graham created KAFKA-6644:
--
Summary: Make Server Info more generic for Kafka Interactive
Queries
Key: KAFKA-6644
URL: https://issues.apache.org/jira/browse/KAFKA-6644
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-6576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396741#comment-16396741
]
ASF GitHub Bot commented on KAFKA-6576:
---
rajinisivaram opened a new pull request #4699: KAFKA-6576:
[
https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Giridhar Addepalli updated KAFKA-6645:
--
Issue Type: New Feature (was: Bug)
> Sticky Partition Assignment across Kafka Streams
Giridhar Addepalli created KAFKA-6645:
-
Summary: Sticky Partition Assignment across Kafka Streams
application restarts
Key: KAFKA-6645
URL: https://issues.apache.org/jira/browse/KAFKA-6645
[
https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Giridhar Addepalli updated KAFKA-6645:
--
Summary: Sticky Partition Assignment to facilitate faster restarts of kafka
streams
[
https://issues.apache.org/jira/browse/KAFKA-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397022#comment-16397022
]
Antonio Verardi commented on KAFKA-4027:
[~tuyuri] I think I am having the exact same issue and on
[
https://issues.apache.org/jira/browse/KAFKA-6634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397130#comment-16397130
]
ASF GitHub Bot commented on KAFKA-6634:
---
guozhangwang closed pull request #4684: KAFKA-6634: Delay
[
https://issues.apache.org/jira/browse/KAFKA-6634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-6634.
--
Resolution: Fixed
Fix Version/s: 1.1.0
> Delay initiating the txn on producers until
[
https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Giridhar Addepalli updated KAFKA-6645:
--
Description:
Since Kafka Streams applications have lot of state in the stores in
Antony Stubbs created KAFKA-6646:
Summary: Add a GlobalKStream object type for stream event broadcast
Key: KAFKA-6646
URL: https://issues.apache.org/jira/browse/KAFKA-6646
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Giridhar Addepalli updated KAFKA-6645:
--
Summary: Host Affinity to facilitate faster restarts of kafka streams
applications
George Bloggs created KAFKA-6647:
Summary: KafkaStreams.cleanUp creates .lock file in directory its
trying to clean
Key: KAFKA-6647
URL: https://issues.apache.org/jira/browse/KAFKA-6647
Project:
[
https://issues.apache.org/jira/browse/KAFKA-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397208#comment-16397208
]
Manikumar commented on KAFKA-4027:
--
More details about similar exception are here:
[
https://issues.apache.org/jira/browse/KAFKA-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397789#comment-16397789
]
ASF GitHub Bot commented on KAFKA-6052:
---
vahidhashemian opened a new pull request #4705: KAFKA-6052:
[
https://issues.apache.org/jira/browse/KAFKA-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julio Ng updated KAFKA-6649:
Affects Version/s: 1.0.0
0.11.0.2
1.0.1
> ReplicaFetcher
Jeremy Custenborder created KAFKA-6651:
--
Summary: SchemaBuilder should not allow Arrays or Maps to be
created by type()
Key: KAFKA-6651
URL: https://issues.apache.org/jira/browse/KAFKA-6651
Julio Ng created KAFKA-6649:
---
Summary: ReplicaFetcher stopped after non fatal exception is thrown
Key: KAFKA-6649
URL: https://issues.apache.org/jira/browse/KAFKA-6649
Project: Kafka
Issue Type:
Lucas Wang created KAFKA-6650:
-
Summary: The controller should be able to handle a partially
deleted topic
Key: KAFKA-6650
URL: https://issues.apache.org/jira/browse/KAFKA-6650
Project: Kafka
radai rosenblatt created KAFKA-6648:
---
Summary: Fetcher.getTopicMetadata() only returns "healthy"
partitions, not all
Key: KAFKA-6648
URL: https://issues.apache.org/jira/browse/KAFKA-6648
Project:
[
https://issues.apache.org/jira/browse/KAFKA-6644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6644:
---
Labels: needs-kip newbie (was: )
> Make Server Info more generic for Kafka Interactive
[
https://issues.apache.org/jira/browse/KAFKA-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-4730:
---
Assignee: John Roesler (was: Nikki Thean)
> Streams does not have an in-memory windowed
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-6648:
Fix Version/s: 2.0.0
> Fetcher.getTopicMetadata() only returns "healthy" partitions, not
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397306#comment-16397306
]
radai rosenblatt commented on KAFKA-6648:
-
PR is https://github.com/apache/kafka/pull/4679
>
[
https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-5697:
-
Labels: newbie (was: )
> StreamThread.close() need to interrupt the stream threads to break the
[
https://issues.apache.org/jira/browse/KAFKA-6644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6644:
---
Description:
when working to implement *kafka streams interactive queries*, i see that i can
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397366#comment-16397366
]
Ted Yu commented on KAFKA-6647:
---
The above code is paired with:
{code}
} finally {
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
George Bloggs updated KAFKA-6647:
-
Description:
When calling kafkaStreams.cleanUp() before starting a stream the
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
George Bloggs updated KAFKA-6647:
-
Environment:
windows 10.
java version "1.8.0_162"
Java(TM) SE Runtime Environment (build
[
https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5697:
---
Description:
In {{StreamThread.shutdown()}} we currently do nothing but set the state,
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-6648:
Affects Version/s: (was: 1.0.1)
1.0.0
[
https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397347#comment-16397347
]
Ted Yu commented on KAFKA-5697:
---
Looks like StreamThread.close() doesn't exist (after refactoring).
>
[
https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-6376:
---
Assignee: John Roesler
> Improve Streams metrics for skipped records
>
[
https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-5697:
---
Summary: StreamThread.shutdown() need to interrupt the stream threads to
break the loop
[
https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-5697:
---
Assignee: John Roesler
> StreamThread.close() need to interrupt the stream threads to break
[
https://issues.apache.org/jira/browse/KAFKA-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398033#comment-16398033
]
Jimin Hsieh commented on KAFKA-6500:
Could you specify more detail? Which version or commit of Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398119#comment-16398119
]
Matthias J. Sax commented on KAFKA-6647:
[~gbloggs] Thanks for reporting the issue. What I am
[
https://issues.apache.org/jira/browse/KAFKA-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-6646:
---
Labels: needs-kip (was: )
> Add a GlobalKStream object type for stream event broadcast
>
[
https://issues.apache.org/jira/browse/KAFKA-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398074#comment-16398074
]
ASF GitHub Bot commented on KAFKA-6649:
---
huxihx opened a new pull request #4707: KAFKA-6649: Should
[
https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398124#comment-16398124
]
ASF GitHub Bot commented on KAFKA-3978:
---
hachikuji closed pull request #4695: KAFKA-3978;
[
https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Giridhar Addepalli updated KAFKA-6645:
--
Description:
Since Kafka Streams applications have lot of state in the stores in
[
https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398118#comment-16398118
]
Matthias J. Sax commented on KAFKA-6645:
This should be supported already. On startup, Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397962#comment-16397962
]
huxihx commented on KAFKA-6651:
---
Instead of throwing exceptions, we could possibly add a couple of `setters`
Lucas Wang created KAFKA-6652:
-
Summary: The controller should log failed attempts to transition a
replica to OfflineReplica state
Key: KAFKA-6652
URL: https://issues.apache.org/jira/browse/KAFKA-6652
56 matches
Mail list logo
