[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529403#comment-16529403
]
Nikolay Izhikov commented on KAFKA-7125:
[~guozhang] Thanks for explanation!
> w
[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529393#comment-16529393
]
Guozhang Wang commented on KAFKA-7125:
--
[~NIzhikov] Note that you do not need to lin
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529390#comment-16529390
]
Ted Yu commented on KAFKA-7126:
---
Maybe we can introduce some jitter (say 1/10 of metadata.m
[
https://issues.apache.org/jira/browse/KAFKA-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529386#comment-16529386
]
Badai Aqrandista commented on KAFKA-6939:
-
[~bgummalla]
Yes, this issue still ex
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529384#comment-16529384
]
Dong Lin commented on KAFKA-7126:
-
[~yuzhih...@gmail.com] Thanks much for your informatio
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7126:
Description:
For a group of 200 MirrorMaker consumers with patten-based topic subscription,
a single topic
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529381#comment-16529381
]
Ted Yu commented on KAFKA-7126:
---
I don't find ConsumerCoordinator.needRejoin() in the code
Dong Lin created KAFKA-7126:
---
Summary: Reduce number of rebalance period for large consumer
groups after a topic is created
Key: KAFKA-7126
URL: https://issues.apache.org/jira/browse/KAFKA-7126
Project: Kaf
[
https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-7126:
Description:
For a group of 200 MirrorMaker consumers with patten-based topic subscription,
a single topic
[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Izhikov reassigned KAFKA-7125:
--
Assignee: Nikolay Izhikov
> Calling StreamsBuilderbuilder.build().describe() causes
>
[
https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529344#comment-16529344
]
Richard Yu commented on KAFKA-6583:
---
This issue will be resolved by KAFKA-4696's PR whi
[
https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Richard Yu reassigned KAFKA-6583:
-
Assignee: Richard Yu
> Metadata should include number of state stores for task
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-7125:
---
Labels: beginner newbie (was: )
> Calling StreamsBuilderbuilder.build().describe() causes
>
[
https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yishun Guan reassigned KAFKA-6755:
--
Assignee: (was: Yishun Guan)
> MaskField SMT should optionally take a literal value to use
[
https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529262#comment-16529262
]
Stephane Maarek commented on KAFKA-7077:
Related but not the same. KAFKA-6340 req
[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529255#comment-16529255
]
Ted Yu commented on KAFKA-7125:
---
I wonder if adding call to {{addGlobalStore}} would change
[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jouni updated KAFKA-7125:
-
Description:
After adding a a processor and a sink to topology after a globalstore and then
calling StreamBuilde
[
https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jouni updated KAFKA-7125:
-
Description:
After adding a a processor and a sink to topology after a globalstore and then
calling StreamBuilde
Jouni created KAFKA-7125:
Summary: Calling StreamsBuilderbuilder.build().describe() causes
java.util.NoSuchElementException: null
Key: KAFKA-7125
URL: https://issues.apache.org/jira/browse/KAFKA-7125
Project:
[
https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-6161:
--
Summary: Add default implementation to close() and configure() for
Serializer, Deserializer and
[
https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-6161:
--
Summary: Make Serializer, Deserializer and Serde be functional interface
(was: Introduce new s
[
https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-6161:
-
Assignee: Chia-Ping Tsai (was: Evgeny Veretennikov)
> Introduce new serdes interfaces w
[
https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529130#comment-16529130
]
Jordan Moore commented on KAFKA-7077:
-
Is this related to KAFKA-6340 ?
> KIP-318: Ma
[
https://issues.apache.org/jira/browse/KAFKA-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-3571.
--
Resolution: Won't Fix
Now AdminClient has support for most of the admin API. This can be used for
test
[
https://issues.apache.org/jira/browse/KAFKA-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-7124.
---
Resolution: Not A Problem
> Number of AnyLogDir should match the length of the replicas list
> --
[
https://issues.apache.org/jira/browse/KAFKA-7123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-7123.
--
Resolution: Fixed
> Documentation: broken link
> http://confluent.io/docs/current/kafka-rest/docs/intr
[
https://issues.apache.org/jira/browse/KAFKA-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529073#comment-16529073
]
Manikumar commented on KAFKA-7124:
--
There is no issue with code. mentioned code generate
[
https://issues.apache.org/jira/browse/KAFKA-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-4122.
--
Resolution: Duplicate
Fixed under KAFKA-7111.
> Consumer startup swallows DNS resolution exception and
[
https://issues.apache.org/jira/browse/KAFKA-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7124:
--
Description:
See discussion under 'Partitions reassignment is failing in Kafka 1.1.0' thread
reported by Debra
Ted Yu created KAFKA-7124:
-
Summary: Number of AnyLogDir should match the length of the
replicas list
Key: KAFKA-7124
URL: https://issues.apache.org/jira/browse/KAFKA-7124
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529034#comment-16529034
]
ASF GitHub Bot commented on KAFKA-6293:
---
ethiebaut closed pull request #4282: KAFKA
31 matches
Mail list logo
