[jira] [Updated] (KAFKA-5919) Delete records command "version" parameter ignored

[ https://issues.apache.org/jira/browse/KAFKA-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5919: -- Fix Version/s: 1.0.0 > Delete records command "version" parameter ignored >

[jira] [Commented] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178558#comment-16178558 ] Paolo Patierno commented on KAFKA-5532: --- [~guozhang] [~ijuma] I have set 1.0.0 version as fix

[jira] [Updated] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5532: -- Fix Version/s: 1.0.0 > Making bootstrap.servers property a first citizen option for the >

[jira] [Created] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

Ted Yu created KAFKA-5967: - Summary: Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() Key: KAFKA-5967 URL: https://issues.apache.org/jira/browse/KAFKA-5967

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178478#comment-16178478 ] Richard Yu commented on KAFKA-4499: --- Thanks for that clarification. I made a rough sketch of the

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178466#comment-16178466 ] Matthias J. Sax commented on KAFKA-4499: First, the description above is just a

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178445#comment-16178445 ] Richard Yu edited comment on KAFKA-4499 at 9/25/17 2:26 AM: So if I am

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178445#comment-16178445 ] Richard Yu edited comment on KAFKA-4499 at 9/25/17 2:25 AM: So if I am

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178445#comment-16178445 ] Richard Yu edited comment on KAFKA-4499 at 9/25/17 2:25 AM: So if I am

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178445#comment-16178445 ] Richard Yu edited comment on KAFKA-4499 at 9/25/17 2:12 AM: So if I am

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178445#comment-16178445 ] Richard Yu commented on KAFKA-4499: --- So if I am understanding this correctly, the methods you have

[jira] [Commented] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178433#comment-16178433 ] ASF GitHub Bot commented on KAFKA-5541: --- GitHub user mjsax opened a pull request:

[jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5541: --- Summary: Streams should not re-throw if suspending/closing tasks fails (was: Streams should

[jira] [Resolved] (KAFKA-5499) Double check how we handle exceptions when commits fail

[ https://issues.apache.org/jira/browse/KAFKA-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5499. Resolution: Duplicate This should be covered by KAFKA-4593 as commit failed exception can

[jira] [Commented] (KAFKA-5929) Save pre-assignment to file to avoid too long text to display when do topic partition reassign

[ https://issues.apache.org/jira/browse/KAFKA-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178422#comment-16178422 ] ASF GitHub Bot commented on KAFKA-5929: --- Github user uncleGen closed the pull request at:

[jira] [Commented] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition

[ https://issues.apache.org/jira/browse/KAFKA-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178423#comment-16178423 ] ASF GitHub Bot commented on KAFKA-5928: --- Github user uncleGen closed the pull request at:

[jira] [Commented] (KAFKA-5217) Improve Streams internal exception handling

[ https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178421#comment-16178421 ] Matthias J. Sax commented on KAFKA-5217: I am not sure if we should ignore **all** exceptions

[jira] [Commented] (KAFKA-5397) streams are not recovering from LockException during rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178418#comment-16178418 ] Matthias J. Sax commented on KAFKA-5397: This might be fixed via KAFKA-4593 -- we should revaluate

[jira] [Updated] (KAFKA-5937) Improve ProcessorStateManager exception handling

[ https://issues.apache.org/jira/browse/KAFKA-5937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5937: --- Description: We identified the follow issues: - constructor calls

[jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing task fails

[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5541: --- Fix Version/s: 1.0.0 > Streams should not re-throw if suspending/closing task fails >

[jira] [Updated] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4593: --- Fix Version/s: 1.0.0 > Task migration during rebalance callback process could lead the

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178406#comment-16178406 ] Ewen Cheslack-Postava commented on KAFKA-5716: -- Sorry, I was just doing a round of cleanup on

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178394#comment-16178394 ] Matthias J. Sax commented on KAFKA-4499: Absolutely. Just compare the current interface

[jira] [Updated] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4499: --- Labels: needs-kip (was: ) > Add "getAllKeys" API for querying windowed KTable stores >

[jira] [Commented] (KAFKA-5958) User StoreListener not available for global stores

[ https://issues.apache.org/jira/browse/KAFKA-5958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178388#comment-16178388 ] Richard Yu commented on KAFKA-5958: --- [~mjsax] Just to clarify on a couple of things, does this only

[jira] [Commented] (KAFKA-5581) Streams can be smarter in deciding when to create changelog topics for state stores

[ https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178363#comment-16178363 ] Jeyhun Karimov commented on KAFKA-5581: --- Hi, [~johnma] is there any updates? > Streams can be

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178290#comment-16178290 ] Richard Yu commented on KAFKA-4499: --- [~mjsax] Is this still relevant? There might have been changes that

[jira] [Commented] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name.

[ https://issues.apache.org/jira/browse/KAFKA-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178207#comment-16178207 ] Charly Molter commented on KAFKA-5890: -- That's what I was expecting. I'll try to get a KIP written

[jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fangjinuo updated KAFKA-4972: - Description: -deleted text-After force shutdown all kafka brokers one by one, restart them one by one,

[jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fangjinuo updated KAFKA-4972: - Description: After force shutdown all kafka brokers one by one, restart them one by one, but a broker

[jira] [Commented] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics

[ https://issues.apache.org/jira/browse/KAFKA-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178119#comment-16178119 ] Ismael Juma commented on KAFKA-5758: Since this is a bug, I'm reassigning to 1.0.0. Let's see if we

[jira] [Updated] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics

[ https://issues.apache.org/jira/browse/KAFKA-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5758: --- Fix Version/s: (was: 1.1.0) 1.0.0 > Reassigning a topic's partitions can

[jira] [Assigned] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics

[ https://issues.apache.org/jira/browse/KAFKA-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5758: -- Assignee: Ismael Juma > Reassigning a topic's partitions can adversely impact other topics >

[jira] [Updated] (KAFKA-4928) Add integration test for DumpLogSegments

[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4928: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Add integration test for DumpLogSegments >

[jira] [Updated] (KAFKA-3096) Leader is not set to -1 when it is shutdown if followers are down

[ https://issues.apache.org/jira/browse/KAFKA-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3096: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Leader is not set to -1 when it is

[jira] [Updated] (KAFKA-5272) Improve validation for Alter Configs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5272: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Improve validation for Alter Configs