[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022614#comment-17022614
]
Matthias J. Sax commented on KAFKA-9471:
Btw: we plan to rework some part of the API and also how
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022595#comment-17022595
]
Ted Yu commented on KAFKA-9471:
---
[~vitojeng]
Looks like the following query depends on the empty collection
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Comment: was deleted
(was: I will send out a PR soon alone the above line of thinking.)
> Throw exception for
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Summary: Throw exception for DEAD StreamThread.State (was: Return empty
collection for PENDING_SHUTDOWN)
>
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Description:
In StreamThreadStateStoreProvider we have:
{code}
if (streamThread.state() ==
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022589#comment-17022589
]
Ted Yu commented on KAFKA-9471:
---
I will send out a PR soon alone the above line of thinking.
> Return
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022586#comment-17022586
]
Vito Jeng commented on KAFKA-9471:
--
Thanks [~yuzhih...@gmail.com] point this.
In KIP-216, we handle
[
https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-8317.
Resolution: Duplicate
Closing this ticket in favor of KAFKA-9259 that duplicates it.
>
[
https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022513#comment-17022513
]
Ewen Cheslack-Postava commented on KAFKA-9468:
--
[~rhauch] Allowing things to run in that
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022400#comment-17022400
]
Matthias J. Sax commented on KAFKA-9471:
Considering KIP-216, I think we need to make sure we
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9471:
---
Component/s: streams
> Return empty collection for PENDING_SHUTDOWN
>
Chris Egerton created KAFKA-9472:
Summary: Reducing number of tasks for connector causes deleted
tasks to show as UNASSIGNED
Key: KAFKA-9472
URL: https://issues.apache.org/jira/browse/KAFKA-9472
Ted Yu created KAFKA-9471:
-
Summary: Return empty collection for PENDING_SHUTDOWN
Key: KAFKA-9471
URL: https://issues.apache.org/jira/browse/KAFKA-9471
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Description:
In StreamThreadStateStoreProvider we have:
{code}
if (streamThread.state() ==
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022373#comment-17022373
]
Ted Yu commented on KAFKA-9471:
---
[~mjsax][~guozhang]
Please comment.
> Return empty collection for
Jason Gustafson created KAFKA-9470:
--
Summary: Hanging test case
`testBlockOnRequestCompletionFromStateChangeHandler`
Key: KAFKA-9470
URL: https://issues.apache.org/jira/browse/KAFKA-9470
Project:
[
https://issues.apache.org/jira/browse/KAFKA-7664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022312#comment-17022312
]
Joel Hamill commented on KAFKA-7664:
[~sudars...@confluent.io] is this covered here?
[
https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022251#comment-17022251
]
Randall Hauch commented on KAFKA-9468:
--
Thanks, [~EeveeB]. I think it makes sense that the Connect
[
https://issues.apache.org/jira/browse/KAFKA-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-7737.
Fix Version/s: 2.5.0
Resolution: Fixed
> Consolidate InitProducerId API
>
[
https://issues.apache.org/jira/browse/KAFKA-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022234#comment-17022234
]
ASF GitHub Bot commented on KAFKA-7737:
---
hachikuji commented on pull request #7920: KAFKA-7737; Use
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 4:09 PM:
---
Hi all,
We
[
https://issues.apache.org/jira/browse/KAFKA-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mollitor updated KAFKA-9411:
--
Description:
Clients and producers should be providing useful {{clientId}} information,
[
https://issues.apache.org/jira/browse/KAFKA-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mollitor updated KAFKA-9411:
--
Summary: Change Name of Default Client ID and Include Java Version (was:
Make Client ID More
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022192#comment-17022192
]
Raman Gupta commented on KAFKA-8803:
[~oleksii.boiko]'s last message inspired me to check for
Ron Dagostino created KAFKA-9469:
Summary: Add zookeeper.ssl.context.supplier.class config if/when
adopting ZooKeeper 3.6
Key: KAFKA-9469
URL: https://issues.apache.org/jira/browse/KAFKA-9469
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022001#comment-17022001
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 12:02 PM:
Original
[
https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021999#comment-17021999
]
hirik commented on KAFKA-9458:
--
[~manme...@gmail.com], I created a git pull request. can you please review
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022001#comment-17022001
]
Oleksii Boiko commented on KAFKA-8803:
--
Original exception full stacktrace(Broker 2.0.1)
[
https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021995#comment-17021995
]
ASF GitHub Bot commented on KAFKA-9458:
---
hirik commented on pull request #8002: KAFKA-9458 Fix
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 11:57 AM:
Hi all,
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 11:49 AM:
Hi all,
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 11:47 AM:
Hi all,
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 11:36 AM:
Hi all,
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 11:35 AM:
Hi all,
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 11:34 AM:
Hi all,
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko edited comment on KAFKA-8803 at 1/23/20 11:32 AM:
Hi all,
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021982#comment-17021982
]
Oleksii Boiko commented on KAFKA-8803:
--
Hi all,
We are facing same issue. The sequence of issue
[
https://issues.apache.org/jira/browse/KAFKA-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-9464.
---
Resolution: Not A Problem
> Close the producer in completeShutdown
> --
[
https://issues.apache.org/jira/browse/KAFKA-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021938#comment-17021938
]
ASF GitHub Bot commented on KAFKA-9464:
---
tedyu commented on pull request #7999: KAFKA-9464: Close
39 matches
Mail list logo
