[jira] [Commented] (KAFKA-6795) Add unit test for ReplicaAlterLogDirsThread

2018-04-23 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449275#comment-16449275 ] Anna Povzner commented on KAFKA-6795: - [~lindong] Before reviewing unit tests, could you please

[jira] [Commented] (KAFKA-6795) Add unit test for ReplicaAlterLogDirsThread

2018-04-23 Thread Anna Povzner (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449252#comment-16449252 ] Anna Povzner commented on KAFKA-6795: - [~lindong] I just wanted to add unit tests for 

[jira] [Commented] (KAFKA-6795) Add unit test for ReplicaAlterLogDirsThread

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16449246#comment-16449246 ] ASF GitHub Bot commented on KAFKA-6795: --- apovzner opened a new pull request #4918: KAFKA-6795: Added

[jira] [Updated] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient

2018-04-23 Thread wade wu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wade wu updated KAFKA-6722: --- Description: In this source code:

[jira] [Updated] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient

2018-04-23 Thread wade wu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wade wu updated KAFKA-6722: --- Description: The lock/unlock of read lock in getOrCreate() is not necessary, or it should be refactored. For

[jira] [Created] (KAFKA-6820) Improve on StreamsMetrics Public APIs

2018-04-23 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6820: Summary: Improve on StreamsMetrics Public APIs Key: KAFKA-6820 URL: https://issues.apache.org/jira/browse/KAFKA-6820 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6819) Refactor build-in StreamsMetrics internal implementations

2018-04-23 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6819: Summary: Refactor build-in StreamsMetrics internal implementations Key: KAFKA-6819 URL: https://issues.apache.org/jira/browse/KAFKA-6819 Project: Kafka

[jira] [Commented] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

2018-04-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448825#comment-16448825 ] Guozhang Wang commented on KAFKA-6670: -- Thanks for the addition [~debasishg] [~seglo], and for your

[jira] [Resolved] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams

2018-04-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6670. -- Resolution: Fixed Fix Version/s: 1.2.0 Issue resolved by pull request 4756

[jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string

2018-04-23 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6684: - Priority: Critical (was: Major) > Support casting values with bytes schema to string >

[jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string

2018-04-23 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6684: - Fix Version/s: 1.2.0 > Support casting values with bytes schema to string >

[jira] [Resolved] (KAFKA-6376) Improve Streams metrics for skipped records

2018-04-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6376. -- Resolution: Fixed Fix Version/s: 1.2.0 Issue resolved by pull request 4812

[jira] [Commented] (KAFKA-6816) Tables in documentation are truncated

2018-04-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448469#comment-16448469 ] Guozhang Wang commented on KAFKA-6816: -- Thanks for the report! Will look into this. > Tables in

[jira] [Resolved] (KAFKA-6815) "default.production.exception.handler" default value is not specified correctly in KafkaStream doc

2018-04-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6815. -- Resolution: Fixed Fix Version/s: 1.0.0 1.1.0 >

[jira] [Commented] (KAFKA-6815) "default.production.exception.handler" default value is not specified correctly in KafkaStream doc

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448427#comment-16448427 ] ASF GitHub Bot commented on KAFKA-6815: --- guozhangwang closed pull request #4914: KAFKA-6815

[jira] [Commented] (KAFKA-6799) Consumer livelock during consumer group rebalance

2018-04-23 Thread Pierre-Henri Dezanneau (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448296#comment-16448296 ] Pierre-Henri Dezanneau commented on KAFKA-6799: --- Thanks a lot [~asasvari], this fixed the

[jira] [Created] (KAFKA-6818) Efficient way to get last n rows via admin client

2018-04-23 Thread Werner Daehn (JIRA)
Werner Daehn created KAFKA-6818: --- Summary: Efficient way to get last n rows via admin client Key: KAFKA-6818 URL: https://issues.apache.org/jira/browse/KAFKA-6818 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

2018-04-23 Thread Omar Al-Safi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448116#comment-16448116 ] Omar Al-Safi commented on KAFKA-6566: - Hey [~rhauch] any further details regarding the correct

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-04-23 Thread Srinivasan Venkatraman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447788#comment-16447788 ] Srinivasan Venkatraman commented on KAFKA-5998: --- I ran into the same issue. Is there an

[jira] [Resolved] (KAFKA-6799) Consumer livelock during consumer group rebalance

2018-04-23 Thread Attila Sasvari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari resolved KAFKA-6799. --- Resolution: Information Provided > Consumer livelock during consumer group rebalance >

[jira] [Assigned] (KAFKA-6799) Consumer livelock during consumer group rebalance

2018-04-23 Thread Attila Sasvari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-6799: - Assignee: Attila Sasvari > Consumer livelock during consumer group rebalance >

[jira] [Updated] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

2018-04-23 Thread Odin Standal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Odin Standal updated KAFKA-6817: Description: We are seeing the following exception in our Kafka application:  {code:java} ERROR

[jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

2018-04-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447699#comment-16447699 ] Ismael Juma commented on KAFKA-6817: cc [~apurva] [~hachikuji] > UnknownProducerIdException when

[jira] [Updated] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

2018-04-23 Thread Odin Standal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Odin Standal updated KAFKA-6817: Description: We are seeing the following exception in our Kafka application: {code:java} ERROR

[jira] [Created] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

2018-04-23 Thread Odin Standal (JIRA)
Odin Standal created KAFKA-6817: --- Summary: UnknownProducerIdException when writing messages with old timestamps Key: KAFKA-6817 URL: https://issues.apache.org/jira/browse/KAFKA-6817 Project: Kafka

[jira] [Created] (KAFKA-6816) Tables in documentation are truncated

2018-04-23 Thread Hashan Gayasri Udugahapattuwa (JIRA)
Hashan Gayasri Udugahapattuwa created KAFKA-6816: Summary: Tables in documentation are truncated Key: KAFKA-6816 URL: https://issues.apache.org/jira/browse/KAFKA-6816 Project: Kafka

[jira] [Commented] (KAFKA-6815) "default.production.exception.handler" default value is not specified correctly in KafkaStream doc

2018-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447608#comment-16447608 ] ASF GitHub Bot commented on KAFKA-6815: --- bistros opened a new pull request #4914: KAFKA-6815

[jira] [Created] (KAFKA-6815) "default.production.exception.handler" default value is not specified correctly in KafkaStream doc

2018-04-23 Thread taekyung kim (JIRA)
taekyung kim created KAFKA-6815: --- Summary: "default.production.exception.handler" default value is not specified correctly in KafkaStream doc Key: KAFKA-6815 URL: https://issues.apache.org/jira/browse/KAFKA-6815