Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Hi, Matthias, Sorry for the late reply. > I am wondering what the semantic impact/change is, if we introduce > `RetryableStateStoreException` and `FatalStateStoreException` that both > inherit from it. While I like the introduction of both from a high level > point of view, I just want to make su

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Hi, Matthias, KIP already updated. > - StateStoreClosedException: > will be wrapped to StateStoreMigratedException or StateStoreNotAvailableException later. > Can you clarify the cases (ie, when will it be wrapped with the one or the other)? For example, in the implementation(CompositeReadOnly

Kafka message set V2

Hi, I'm working on an implementation of kafka client for go. It's a client written fully in go: https://github.com/segmentio/kafka-go This library doesn't seem to support message set V2 and it throws errors that v2 message format can't be handled. However I'm having troubles getting a stable repr

Re: [DISCUSS] KIP-258: Allow to Store Record Timestamps in RocksDB

Adam, I am still working on it. Was pulled into a lot of other tasks lately so this was delayed. Also had some discussions about simplifying the upgrade path with some colleagues and I am prototyping this atm. Hope to update the KIP accordingly soon. -Matthias On 11/10/18 7:41 AM, Adam Bellemare

Re: [VOTE] 2.1.0 RC1

Hello, +1 I have downloaded the release artifact from http://home.apache.org/~lindong/kafka-2.1.0-rc1/ Executed a 3 brokers cluster. (java8 8u192b12) Executed kafka-monitor for about 1 hour without problems. Thanks, -- Jonathan On Fri, Nov 9, 2018 at 11:33 PM Dong Lin wrote: > Hello Kafka us

[jira] [Created] (KAFKA-7615) Support different topic name in source and destination server in Mirrormaker

Adeeti Kaushal created KAFKA-7615: - Summary: Support different topic name in source and destination server in Mirrormaker Key: KAFKA-7615 URL: https://issues.apache.org/jira/browse/KAFKA-7615 Project:

[jira] [Created] (KAFKA-7616) MockConsumer can return ConsumerRecords objects with a non-empty map but no records

Stig Rohde Døssing created KAFKA-7616: - Summary: MockConsumer can return ConsumerRecords objects with a non-empty map but no records Key: KAFKA-7616 URL: https://issues.apache.org/jira/browse/KAFKA-7616

Re: [VOTE] KIP-374: Add '--help' option to all available Kafka CLI commands

+1 (non-binding) Il ven 9 nov 2018, 02:09 Colin McCabe ha scritto: > +1 (binding) > > > > On Wed, Oct 31, 2018, at 05:42, Srinivas Reddy wrote: > > Hi All, > > > > I would like to call for a vote on KIP-374: > > https://cwiki.apache.org/confluence/x/FgSQBQ > > > > Summary: > > Currently, the '--

Re: [VOTE] KIP-374: Add '--help' option to all available Kafka CLI commands

+1 (binding) -Harsha On Nov 11, 2018, 3:49 PM -0800, Daniele Ascione , wrote: > +1 (non-binding) > > Il ven 9 nov 2018, 02:09 Colin McCabe ha scritto: > > > +1 (binding) > > > > > > > > On Wed, Oct 31, 2018, at 05:42, Srinivas Reddy wrote: > > > Hi All, > > > > > > I would like to call for a vote

[jira] [Resolved] (KAFKA-7590) GETTING HUGE MESSAGE STRUCTURE THROUGH JMS CONNECTOR

[ https://issues.apache.org/jira/browse/KAFKA-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenchu Lakshman kumar resolved KAFKA-7590. --- Resolution: Fixed > GETTING HUGE MESSAGE STRUCTURE THROUGH JMS CONNECTOR > --

Re: [VOTE] KIP-374: Add '--help' option to all available Kafka CLI commands

Thanks for the KIP. +1 (binding). On Mon, Nov 12, 2018 at 9:59 AM Harsha Chintalapani wrote: > +1 (binding) > > -Harsha > On Nov 11, 2018, 3:49 PM -0800, Daniele Ascione , > wrote: > > +1 (non-binding) > > > > Il ven 9 nov 2018, 02:09 Colin McCabe ha scritto: > > > > > +1 (binding) > > > > > >