[jira] [Work started] (KAFKA-3915) LogCleaner IO buffers do not account for potential size difference due to message format change

2016-07-16 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3915 started by Ismael Juma. -- > LogCleaner IO buffers do not account for potential size difference due to > messag

Re: [VOTE] KIP-67: Queryable state for Kafka Streams

2016-07-16 Thread Damian Guy
Hi, Jay's interpretation is correct. Thanks, Damian On Fri, 15 Jul 2016 at 16:10, Jay Kreps wrote: > My interpretation was that you need an implementation of > QueryableStoreType which anyone can do and QueryableStoreTypes is just a > place to put the type objects for the types we ship with Kafk

Re: [VOTE] KIP-67: Queryable state for Kafka Streams

2016-07-16 Thread Damian Guy
Hi, The vote is now complete and KIP-67 has been accepted and adopted. Thanks everyone for the input etc. Regards, Damian On Sat, 16 Jul 2016 at 06:53 Damian Guy wrote: > Hi, > Jay's interpretation is correct. > Thanks, > Damian > > > On Fri, 15 Jul 2016 at 16:10, Jay Kreps wrote: > >> My inte

Re: [DISCUSS] KIP-66 Kafka Connect Transformers for messages

2016-07-16 Thread Nisarg Shah
Gwen, Yup, that sounds great! Instead of keeping it up to the transformers to handle null, we can instead have the topic as null. Sounds good. To get rid of a message, set the topic to a special one (could be as simple as null). Like I said before, the more interesting part would be ‘adding’

[jira] [Created] (KAFKA-3969) kafka.admin.ConsumerGroupCommand doesn't show consumer groups

2016-07-16 Thread Dieter Plaetinck (JIRA)
Dieter Plaetinck created KAFKA-3969: --- Summary: kafka.admin.ConsumerGroupCommand doesn't show consumer groups Key: KAFKA-3969 URL: https://issues.apache.org/jira/browse/KAFKA-3969 Project: Kafka

[jira] [Commented] (KAFKA-3961) broker sends malformed response when switching from no compression to snappy/gzip

2016-07-16 Thread Dieter Plaetinck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380940#comment-15380940 ] Dieter Plaetinck commented on KAFKA-3961: - So I noticed I don't even have to switc

[jira] [Updated] (KAFKA-3960) Committed offset not set after first assign

2016-07-16 Thread Alexey Romanchuk (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanchuk updated KAFKA-3960: Description: Committed offset did not set after first assign. Here it is minimal example (s