[jira] [Commented] (KAFKA-6742) TopologyTestDriver error when dealing with stores from GlobalKTable

2018-04-03 Thread Valentino Proietti (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425091#comment-16425091 ] Valentino Proietti commented on KAFKA-6742: --- Hello [~guozhang], I will create th

[jira] [Updated] (KAFKA-6730) Simplify state store recovery

2018-04-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6730: --- Description: In the current code base, we restore state stores in the main thread (in contras

[jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424885#comment-16424885 ] ASF GitHub Bot commented on KAFKA-6560: --- guozhangwang closed pull request #4814: KAF

[jira] [Commented] (KAFKA-6678) Upgrade dependencies with later release versions

2018-04-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424881#comment-16424881 ] Ismael Juma commented on KAFKA-6678: Are you sure you ran the tool with the latest tru

[jira] [Updated] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6531: -- Description: >From >https://builds.apache.org/job/kafka-trunk-jdk9/361/testReport/junit/kafka.network/SocketSer

[jira] [Updated] (KAFKA-6678) Upgrade dependencies with later release versions

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6678: -- Component/s: build > Upgrade dependencies with later release versions >

[jira] [Assigned] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

2018-04-03 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-6729: -- Assignee: Bill Bejeck > KTable should use user source topics if possible and not create changel

[jira] [Created] (KAFKA-6745) kafka consumer rebalancing takes long time (from 3 secs to 5 minutes)

2018-04-03 Thread Ramkumar (JIRA)
Ramkumar created KAFKA-6745: --- Summary: kafka consumer rebalancing takes long time (from 3 secs to 5 minutes) Key: KAFKA-6745 URL: https://issues.apache.org/jira/browse/KAFKA-6745 Project: Kafka Is

[jira] [Commented] (KAFKA-3240) Replication issues

2018-04-03 Thread Ari Uka (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424420#comment-16424420 ] Ari Uka commented on KAFKA-3240: I'm running into the same issue. https://issues.apache.o

[jira] [Created] (KAFKA-6744) MockProducer with transaction enabled doesn't fail on commit if a record was failed

2018-04-03 Thread JIRA
Pascal GĂ©linas created KAFKA-6744: - Summary: MockProducer with transaction enabled doesn't fail on commit if a record was failed Key: KAFKA-6744 URL: https://issues.apache.org/jira/browse/KAFKA-6744 P

[jira] [Updated] (KAFKA-6739) Down-conversion fails for records with headers

2018-04-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6739: --- Summary: Down-conversion fails for records with headers (was: Broker receives error when hand

[jira] [Resolved] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

2018-04-03 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6739. Resolution: Fixed Fix Version/s: 1.0.2 > Broker receives error when handling request

[jira] [Commented] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424336#comment-16424336 ] ASF GitHub Bot commented on KAFKA-6739: --- hachikuji closed pull request #4813: KAFKA-

[jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE

2018-04-03 Thread Khaireddine Rezgui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424263#comment-16424263 ] Khaireddine Rezgui commented on KAFKA-6535: --- Thank you [~vvcephei], i will take

[jira] [Commented] (KAFKA-6742) TopologyTestDriver error when dealing with stores from GlobalKTable

2018-04-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424242#comment-16424242 ] Guozhang Wang commented on KAFKA-6742: -- Hello [~vale68] Thanks for reporting the issu

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

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424234#comment-16424234 ] ASF GitHub Bot commented on KAFKA-6684: --- amitsela opened a new pull request #4820: K

[jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424197#comment-16424197 ] ASF GitHub Bot commented on KAFKA-6728: --- ewencp closed pull request #4815: KAFKA-672

[jira] [Assigned] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6728: Assignee: Randall Hauch > Kafka Connect Header Null Pointer Exception > ---

[jira] [Resolved] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6728. -- Resolution: Fixed Fix Version/s: 1.1.1 1.2.0 Issue res

[jira] [Commented] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions

2018-04-03 Thread Alex Dunayevsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424145#comment-16424145 ] Alex Dunayevsky commented on KAFKA-6743: https://github.com/apache/kafka/pull/4818

[jira] [Commented] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424114#comment-16424114 ] ASF GitHub Bot commented on KAFKA-6724: --- rootex- opened a new pull request #4818: KA

[jira] [Created] (KAFKA-6743) ConsumerPerformance fails to consume all messages on topics with large number of partitions

2018-04-03 Thread Alex Dunayevsky (JIRA)
Alex Dunayevsky created KAFKA-6743: -- Summary: ConsumerPerformance fails to consume all messages on topics with large number of partitions Key: KAFKA-6743 URL: https://issues.apache.org/jira/browse/KAFKA-6743

[jira] [Assigned] (KAFKA-6740) Plugins class' newConverter and newHeaderConverter methods are unclear

2018-04-03 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-6740: Assignee: Randall Hauch > Plugins class' newConverter and newHeaderConverter methods are un

[jira] [Updated] (KAFKA-6742) TopologyTestDriver error when dealing with stores from GlobalKTable

2018-04-03 Thread Valentino Proietti (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentino Proietti updated KAFKA-6742: -- Description: {color:#ff}This junit test simply fails:{color} @Test *public* *void*

[jira] [Created] (KAFKA-6742) TopologyTestDriver error when dealing with stores from GlobalKTable

2018-04-03 Thread Valentino Proietti (JIRA)
Valentino Proietti created KAFKA-6742: - Summary: TopologyTestDriver error when dealing with stores from GlobalKTable Key: KAFKA-6742 URL: https://issues.apache.org/jira/browse/KAFKA-6742 Project:

[jira] [Updated] (KAFKA-6741) Transient test failure: SslTransportLayerTest.testNetworkThreadTimeRecorded

2018-04-03 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-6741: - Description: debug logs: {code} [2018-04-03 14:51:33,365] DEBUG Added sensor with name connections-close

[jira] [Created] (KAFKA-6741) Transient test failure: SslTransportLayerTest.testNetworkThreadTimeRecorded

2018-04-03 Thread Manikumar (JIRA)
Manikumar created KAFKA-6741: Summary: Transient test failure: SslTransportLayerTest.testNetworkThreadTimeRecorded Key: KAFKA-6741 URL: https://issues.apache.org/jira/browse/KAFKA-6741 Project: Kafka

[jira] [Commented] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started"

2018-04-03 Thread Chema Sanchez (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423791#comment-16423791 ] Chema Sanchez commented on KAFKA-6683: -- [~hachikuji] I have been unable to reproduce

[jira] [Comment Edited] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423740#comment-16423740 ] Philippe Hong edited comment on KAFKA-6728 at 4/3/18 9:36 AM: --

[jira] [Comment Edited] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423740#comment-16423740 ] Philippe Hong edited comment on KAFKA-6728 at 4/3/18 9:36 AM: --

[jira] [Comment Edited] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423740#comment-16423740 ] Philippe Hong edited comment on KAFKA-6728 at 4/3/18 9:35 AM: --

[jira] [Comment Edited] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423740#comment-16423740 ] Philippe Hong edited comment on KAFKA-6728 at 4/3/18 9:35 AM: --

[jira] [Comment Edited] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423740#comment-16423740 ] Philippe Hong edited comment on KAFKA-6728 at 4/3/18 9:35 AM: --

[jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-04-03 Thread Philippe Hong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423740#comment-16423740 ] Philippe Hong commented on KAFKA-6728: -- Thank you, adding header.converter=org.apache