[jira] [Commented] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

2017-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290367#comment-16290367 ] ASF GitHub Bot commented on KAFKA-5092: --- Github user simplesteph closed the pull request at:

[jira] [Commented] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower

2017-12-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290268#comment-16290268 ] Jason Gustafson commented on KAFKA-6361: Unclean leader election was disabled. It may not have

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

2017-12-13 Thread Sean Policarpio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290260#comment-16290260 ] Sean Policarpio commented on KAFKA-2260: We also desire optimistic concurrency control for our

[jira] [Commented] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower

2017-12-13 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290252#comment-16290252 ] Jun Rao commented on KAFKA-6361: Was unclean leader election enabled in this case? When broker B takes

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

2017-12-13 Thread Jed Wesley-Smith (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290245#comment-16290245 ] Jed Wesley-Smith commented on KAFKA-2260: - This would be a valuable feature, currently we need

[jira] [Commented] (KAFKA-5849) Add process stop faults, round trip workload, partitioned produce-consume test

2017-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290205#comment-16290205 ] ASF GitHub Bot commented on KAFKA-5849: --- GitHub user cmccabe opened a pull request:

[jira] [Commented] (KAFKA-5849) Add process stop faults, round trip workload, partitioned produce-consume test

2017-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290197#comment-16290197 ] ASF GitHub Bot commented on KAFKA-5849: --- Github user cmccabe closed the pull request at:

[jira] [Updated] (KAFKA-5849) Add process stop faults, round trip workload, partitioned produce-consume test

2017-12-13 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-5849: --- Summary: Add process stop faults, round trip workload, partitioned produce-consume test

[jira] [Created] (KAFKA-6361) Fast leader fail over can lead to log divergence between replica and follower

2017-12-13 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6361: -- Summary: Fast leader fail over can lead to log divergence between replica and follower Key: KAFKA-6361 URL: https://issues.apache.org/jira/browse/KAFKA-6361

[jira] [Commented] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read

2017-12-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290140#comment-16290140 ] huxihx commented on KAFKA-6345: --- A easy-thinking solution is to create a safe count method only for JMX

[jira] [Commented] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

2017-12-13 Thread William Austin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290110#comment-16290110 ] William Austin commented on KAFKA-6252: --- [~rhauch] are there any workarounds for this issue until it

[jira] [Comment Edited] (KAFKA-6339) Integration test with embedded kafka not working

2017-12-13 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290024#comment-16290024 ] Narendra Kumar edited comment on KAFKA-6339 at 12/13/17 10:13 PM: -- Hi

[jira] [Commented] (KAFKA-6339) Integration test with embedded kafka not working

2017-12-13 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290024#comment-16290024 ] Narendra Kumar commented on KAFKA-6339: --- Hi Dhruv, Can you please enable debug logging and provide

[jira] [Assigned] (KAFKA-6352) Delay message down-conversion until response is ready to be sent

2017-12-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6352: -- Assignee: Jason Gustafson > Delay message down-conversion until response is ready to

[jira] [Commented] (KAFKA-6126) Reduce rebalance time by not checking if created topics are available

2017-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289929#comment-16289929 ] ASF GitHub Bot commented on KAFKA-6126: --- GitHub user mjsax opened a pull request:

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

2017-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289883#comment-16289883 ] ASF GitHub Bot commented on KAFKA-6018: --- Github user xvrl closed the pull request at:

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-13 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289773#comment-16289773 ] Manikumar commented on KAFKA-6335: -- SimpleAclAuthorizer#updateResourceAcls() will retry incase of any

[jira] [Updated] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails

2017-12-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6232: -- Labels: security (was: ) > SaslSslAdminClientIntegrationTest sometimes fails >

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289701#comment-16289701 ] Guozhang Wang commented on KAFKA-6335: -- Encountered this test failure again on Jenkins:

[jira] [Updated] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies

2017-12-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6355: --- Component/s: unit tests > transient failure in >

[jira] [Commented] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

2017-12-13 Thread Neerja Khattar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289584#comment-16289584 ] Neerja Khattar commented on KAFKA-6336: --- [~huxi_2b] [~hachikuji] any update? > when using assign()

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289550#comment-16289550 ] Ted Yu commented on KAFKA-6335: --- SimpleAclAuthorizer#updateResourceAcls() returns boolean, indicating

[jira] [Updated] (KAFKA-6086) Provide for custom error handling when Kafka Streams fails to produce

2017-12-13 Thread Matt Farmer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Farmer updated KAFKA-6086: --- Summary: Provide for custom error handling when Kafka Streams fails to produce (was: KIP-210 Provide

[jira] [Commented] (KAFKA-6086) Provide for custom error handling when Kafka Streams fails to produce

2017-12-13 Thread Matt Farmer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289370#comment-16289370 ] Matt Farmer commented on KAFKA-6086: The associated KIP has been accepted, the PR is ready for further

[jira] [Assigned] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

2017-12-13 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-4125: - Assignee: (was: Jeyhun Karimov) > Provide low-level Processor API meta data in DSL

[jira] [Assigned] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2017-12-13 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-6035: - Assignee: (was: Jeyhun Karimov) > Avoid creating changelog topics for state stores

[jira] [Assigned] (KAFKA-5581) Avoid creating changelog topics for state stores that are materialized from a source topic

2017-12-13 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-5581: - Assignee: (was: Jeyhun Karimov) > Avoid creating changelog topics for state stores

[jira] [Assigned] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key

2017-12-13 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-4304: - Assignee: (was: Jeyhun Karimov) > Extend Interactive Queries for return latest

[jira] [Created] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

2017-12-13 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-6360: - Summary: RocksDB segments not removed when store is closed causes re-initialization to fail Key: KAFKA-6360 URL: https://issues.apache.org/jira/browse/KAFKA-6360 Project:

[jira] [Created] (KAFKA-6359) Work for KIP-236

2017-12-13 Thread Tom Bentley (JIRA)
Tom Bentley created KAFKA-6359: -- Summary: Work for KIP-236 Key: KAFKA-6359 URL: https://issues.apache.org/jira/browse/KAFKA-6359 Project: Kafka Issue Type: Improvement Reporter: Tom

[jira] [Commented] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings

2017-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16289131#comment-16289131 ] ASF GitHub Bot commented on KAFKA-6342: --- GitHub user umesh9794 opened a pull request:

[jira] [Created] (KAFKA-6358) Per topic producer/fetch_consumer/fetch_follower metrics

2017-12-13 Thread Ricardo Bartolome (JIRA)
Ricardo Bartolome created KAFKA-6358: Summary: Per topic producer/fetch_consumer/fetch_follower metrics Key: KAFKA-6358 URL: https://issues.apache.org/jira/browse/KAFKA-6358 Project: Kafka

[jira] [Created] (KAFKA-6357) Return nonzero code in kafka-consumer-groups.sh tool in case of error

2017-12-13 Thread Rinat Shigapov (JIRA)
Rinat Shigapov created KAFKA-6357: - Summary: Return nonzero code in kafka-consumer-groups.sh tool in case of error Key: KAFKA-6357 URL: https://issues.apache.org/jira/browse/KAFKA-6357 Project: Kafka

[jira] [Created] (KAFKA-6356) UnknownTopicOrPartitionException & NotLeaderForPartitionException and log deletion happening with retention bytes kept at -1.

2017-12-13 Thread kaushik srinivas (JIRA)
kaushik srinivas created KAFKA-6356: --- Summary: UnknownTopicOrPartitionException & NotLeaderForPartitionException and log deletion happening with retention bytes kept at -1. Key: KAFKA-6356 URL: