Null Pointer Exception for KTable, Can someone suggest?

vivek sharma

unread,

Feb 8, 2017, 12:50:57 PM2/8/17

to Confluent Platform

Hi Mates - Got the below exception, does someone knows what triggered this exception? tried with JSON and String got the same error, is the below code not following correct approach? if not how will I take an Array of several JSONs and filter some of JSONs out of and array of several JSONs based on some fields and their values in JSON and to publish filtered JSONs to corresponding topics? I am not getting this issue without KTable, Sorry to bombard very basic stuffs here:

KStreamBuilder builder = new KStreamBuilder();

KTable<JsonNode, JsonNode> businessProcess = builder.table("test");

businessProcess.groupBy((BusinessProcessName, loadPlan) -> KeyValue.pair(BusinessProcessName, loadPlan));

businessProcess.toStream().to(jsonSerde, jsonSerde, "test1");

Exception in thread "StreamThread-2" java.lang.NullPointerException
        at org.rocksdb.RocksDB.get(RocksDB.java:731)
        at org.apache.kafka.streams.state.internals.RocksDBStore.getInternal(RocksDBStore.java:255)
        at org.apache.kafka.streams.state.internals.RocksDBStore.get(RocksDBStore.java:241)
        at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.get(MeteredKeyValueStore.java:100)
        at org.apache.kafka.streams.kstream.internals.KTableSource$MaterializedKTableSourceProcessor.process(KTableSource.java:74)
        at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68)
        at org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338)
        at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187)
        at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:64)
        at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:174)
        at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:320)
        at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218)
Exception in thread "StreamThread-3" org.apache.kafka.streams.errors.StreamsException: Failed to rebalance
        at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:299)
        at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218)
Caused by: java.lang.NullPointerException
        at org.rocksdb.RocksDB.put(RocksDB.java:432)
        at org.apache.kafka.streams.state.internals.RocksDBStore.putInternal(RocksDBStore.java:298)
        at org.apache.kafka.streams.state.internals.RocksDBStore.access$200(RocksDBStore.java:62)
        at org.apache.kafka.streams.state.internals.RocksDBStore$3.restore(RocksDBStore.java:205)
        at org.apache.kafka.streams.processor.internals.ProcessorStateManager.restoreActiveState(ProcessorStateManager.java:245)
        at org.apache.kafka.streams.processor.internals.ProcessorStateManager.register(ProcessorStateManager.java:210)
        at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.register(ProcessorContextImpl.java:116)
        at org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:201)
        at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore.java:85)
        at org.apache.kafka.streams.processor.internals.AbstractTask.initializeStateStores(AbstractTask.java:81)
        at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:115)
        at org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:550)
        at org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:577)
        at org.apache.kafka.streams.processor.internals.StreamThread.access$000(StreamThread.java:68)
        at org.apache.kafka.streams.processor.internals.StreamThread$1.onPartitionsAssigned(StreamThread.java:123)
        at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:222)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.onSuccess(AbstractCoordinator.java:232)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.onSuccess(AbstractCoordinator.java:227)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
        at org.apache.kafka.clients.consumer.internals.RequestFuture$2.onSuccess(RequestFuture.java:182)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:436)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:422)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:679)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:658)
        at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:167)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:426)
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:278)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:243)
        at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:345)
        at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:977)
        at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:937)
        at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:295)
        ... 1 more
^[OB^[OBException in thread "StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Failed to rebalance
        at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:299)
        at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218)
Caused by: org.apache.kafka.streams.errors.ProcessorStateException: Error while creating the state manager
        at org.apache.kafka.streams.processor.internals.AbstractTask.<init>(AbstractTask.java:71)
        at org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:86)
        at org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:550)
        at org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:577)
        at org.apache.kafka.streams.processor.internals.StreamThread.access$000(StreamThread.java:68)
        at org.apache.kafka.streams.processor.internals.StreamThread$1.onPartitionsAssigned(StreamThread.java:123)
        at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:222)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.onSuccess(AbstractCoordinator.java:232)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.onSuccess(AbstractCoordinator.java:227)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
        at org.apache.kafka.clients.consumer.internals.RequestFuture$2.onSuccess(RequestFuture.java:182)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:436)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:422)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:679)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:658)
        at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:167)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:426)
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:278)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:243)
        at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:345)
        at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:977)
        at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:937)
        at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:295)
        ... 1 more
Caused by: java.io.IOException: Failed to lock the state directory: /tmp/kafka-streams/Kafka Streams Spike/0_0
        at org.apache.kafka.streams.processor.internals.ProcessorStateManager.<init>(ProcessorStateManager.java:95)
        at org.apache.kafka.streams.processor.internals.AbstractTask.<init>(AbstractTask.java:69)
        ... 32 more

Eno Thereska

unread,

Feb 8, 2017, 3:26:46 PM2/8/17

to Confluent Platform

Could you confirm what version of Kafka you are using. The error seems to be :
"Failed to lock the state directory: /tmp/kafka-streams/Kafka Streams Spike/0_0" which we used to have before but it was fixed recently. Could you try trunk? 0.10.2 is currently being voted and should come out any time now too.

Thanks

Eno

vivek sharma

unread,

Feb 8, 2017, 8:03:23 PM2/8/17

to Confluent Platform

Earlier I was using 0.10.1.x with Kafka 0.10.0.0 but that version did not work with Kafka 0.10.0.0, Will 0.10.2 work with Kafka 0.10.0.0?

Matthias J. Sax

unread,

Feb 9, 2017, 1:05:52 AM2/9/17

to confluent...@googlegroups.com

Unfortunately, Kafka Streams 0.10.2 will _not_ work with 0.10.0 brokers
-- it's only backward compatible to 0.10.1 brokers.

This limitation will be there for any future release, too. Kafka Streams
will never be backward compatible to 0.10.0 brokers. :(

-Matthias

> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send
> an email to confluent-platf...@googlegroups.com
> <mailto:confluent-platf...@googlegroups.com>.
> To post to this group, send email to confluent...@googlegroups.com
> <mailto:confluent...@googlegroups.com>.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout.

signature.asc

vivek sharma

unread,

Feb 9, 2017, 1:45:45 AM2/9/17

to Confluent Platform

Thank you Matthias, Is there any future plan that Kafka Streams 0.10.2 be backward compatible with at least Kafka 0.10.0 soon in near future?

> an email to confluent-platform+unsub...@googlegroups.com
> <mailto:confluent-platform+unsub...@googlegroups.com>.

Damian Guy

unread,

Feb 9, 2017, 2:46:11 AM2/9/17

to Confluent Platform

Hi Vivek,

As Matthias mentioned, 0.10.2 will never be backward compatible with 0.10.0.

Thanks,

Damian

> an email to confluent-platf...@googlegroups.com
> <mailto:confluent-platf...@googlegroups.com>.

> To post to this group, send email to confluent...@googlegroups.com
> <mailto:confluent...@googlegroups.com>.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout.

--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.

To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com.

vivek sharma

unread,

Feb 9, 2017, 10:48:26 AM2/9/17

to Confluent Platform

Got it. If I use Confluent Enterprise 3.0 Compute Cluster with Microsoft Azure, I guess I can use the latest features of Kafka Streams 0.10.2 assuming Kafka Streams will be running in Virtual Machines?

> an email to confluent-platform+unsub...@googlegroups.com
> <mailto:confluent-platform+unsub...@googlegroups.com>.

> To post to this group, send email to confluent...@googlegroups.com
> <mailto:confluent...@googlegroups.com>.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout.

--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.

To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.

Matthias J. Sax

unread,

Feb 9, 2017, 1:55:18 PM2/9/17

to confluent...@googlegroups.com

No. A Kafka Stream 0.10.2 (ie CP 3.2) app cannot connect to brokers with
version 0.10.0 (ie CP 3.0).

-Matthias

> > an email to confluent-platf...@googlegroups.com
> > <mailto:confluent-platf...@googlegroups.com>.

>
> > To post to this group, send email to
> confluent...@googlegroups.com
> > <mailto:confluent...@googlegroups.com>.
>
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com>
>
> >

> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer

> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>
> > For more options, visit https://groups.google.com/d/optout

> <https://groups.google.com/d/optout>.

>
> --
> You received this message because you are subscribed to the
> Google Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from
> it, send an email to

> confluent-platf...@googlegroups.com <javascript:>.

> To post to this group, send email to

> confluent...@googlegroups.com <javascript:>.

> To view this discussion on the web visit

> https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com?utm_medium=email&utm_source=footer>.

> For more options, visit https://groups.google.com/d/optout

> <https://groups.google.com/d/optout>.

>
> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send

> an email to confluent-platf...@googlegroups.com
> <mailto:confluent-platf...@googlegroups.com>.

> To post to this group, send email to confluent...@googlegroups.com
> <mailto:confluent...@googlegroups.com>.
> To view this discussion on the web visit

> https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer>.

signature.asc

vivek sharma

unread,

Feb 9, 2017, 2:16:33 PM2/9/17

to Confluent Platform

Interesting, Got another question - If I start to use CP 3.0 in current production, Will version upgrade from CP 3.0 to CP 3.2 will be easy?

> > an email to confluent-platform+unsub...@googlegroups.com
> > <mailto:confluent-platform+unsub...@googlegroups.com>.

>
> > To post to this group, send email to
> confluent...@googlegroups.com
> > <mailto:confluent...@googlegroups.com>.
>
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>
> > For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> You received this message because you are subscribed to the
> Google Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from
> it, send an email to

> confluent-platform+unsub...@googlegroups.com <javascript:>.

> To post to this group, send email to
> confluent...@googlegroups.com <javascript:>.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send

> an email to confluent-platform+unsub...@googlegroups.com
> <mailto:confluent-platform+unsub...@googlegroups.com>.

Matthias J. Sax

unread,

Feb 9, 2017, 2:36:52 PM2/9/17

to confluent...@googlegroups.com

It should be fairly easy. Confluent has an upgrade guide you can follow:
http://docs.confluent.io/current/upgrade.html

For Streams, as a quite new API, there are backward incompatible changes
in the API that require you to rewrite some parts of your code if you
upgrade.

There is also a Streams specific upgrade guide:
http://docs.confluent.io/current/streams/upgrade-guide.html

Breaking changes are summarized there, too (pay attention about the
version -- bug-fix released have no breaking API changes, but minor
released do). So you need to read the correct upgrade guide (versions
ending with zero, i.e. CP x.y.0, describe breaking changes)

For example
http://docs.confluent.io/3.1.0/streams/upgrade-guide.html

-Matthias

> confluent-platf...@googlegroups.com <javascript:>
> > >
> <mailto:confluent-platf...@googlegroups.com <javascript:>>.

> >
> > > To post to this group, send email to
> > confluent...@googlegroups.com

> > confluent-platf...@googlegroups.com
> <javascript:> <javascript:>.

> > To post to this group, send email to
> > confluent...@googlegroups.com <javascript:>.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com>
>
> >

> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com?utm_medium=email&utm_source=footer

> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>
> > For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>

> > <https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>>.
> >
> > --
> > You received this message because you are subscribed to the Google
> > Groups "Confluent Platform" group.
> > To unsubscribe from this group and stop receiving emails from it,
> send

> > an email to confluent-platf...@googlegroups.com
> <javascript:>
> > <mailto:confluent-platf...@googlegroups.com

> <javascript:>>.
> > To post to this group, send email to confluent...@googlegroups.com
> <javascript:>

> > <mailto:confluent...@googlegroups.com <javascript:>>.

> > To view this discussion on the web visit
> >

> https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>

> > For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send

> an email to confluent-platf...@googlegroups.com
> <mailto:confluent-platf...@googlegroups.com>.

> To post to this group, send email to confluent...@googlegroups.com
> <mailto:confluent...@googlegroups.com>.
> To view this discussion on the web visit

> https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com?utm_medium=email&utm_source=footer>.

signature.asc

vivek sharma

unread,

Feb 9, 2017, 2:46:09 PM2/9/17

to Confluent Platform

Thanks Matthias to share this information, Looks like CP 3.2 is already out, When I can see that in Azure Marketplace? Marketplace still shows CP 3.0

> confluent-platform+unsub...@googlegroups.com <javascript:>
> > >
> <mailto:confluent-platform+unsub...@googlegroups.com <javascript:>>.

> >
> > > To post to this group, send email to
> > confluent...@googlegroups.com
> > > <mailto:confluent...@googlegroups.com>.
> >
> > > To view this discussion on the web visit
> > >
> >
> https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com>>
>
> >
> > >
> >
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/31d97741-943a-4fe0-a230-25098f8b891f%40googlegroups.com?utm_medium=email&utm_source=footer>>>.
>
> >
> > > For more options, visit
> https://groups.google.com/d/optout <https://groups.google.com/d/optout>
> > <https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>>.
> >
> > --
> > You received this message because you are subscribed to the
> > Google Groups "Confluent Platform" group.
> > To unsubscribe from this group and stop receiving emails from
> > it, send an email to

> > confluent-platform+unsub...@googlegroups.com

> <javascript:> <javascript:>.
> > To post to this group, send email to
> > confluent...@googlegroups.com <javascript:>.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/6e6e58fc-1562-421b-a3f9-c2dcd97eb033%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>
> > For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>
> > <https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>>.
> >
> > --
> > You received this message because you are subscribed to the Google
> > Groups "Confluent Platform" group.
> > To unsubscribe from this group and stop receiving emails from it,
> send

> > an email to confluent-platform+unsub...@googlegroups.com
> <javascript:>
> > <mailto:confluent-platform+unsub...@googlegroups.com

> <javascript:>>.
> > To post to this group, send email to confluent...@googlegroups.com
> <javascript:>
> > <mailto:confluent...@googlegroups.com <javascript:>>.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>
> > For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send

> an email to confluent-platform+unsub...@googlegroups.com
> <mailto:confluent-platform+unsub...@googlegroups.com>.

Matthias J. Sax

unread,

Feb 9, 2017, 3:58:32 PM2/9/17

to confluent...@googlegroups.com, David Tucker

CP 3.2.0 is not out yet. It's going to be released in the next weeks.

Current latest version is CP 3.1.1. I have no idea when CP 3.2.0 will be
available in Azure Marketplace. Maybe David knows (cc'ed him).

-Matthias

> > confluent-platf...@googlegroups.com <javascript:>
> <javascript:>
> > > >
> > <mailto:confluent-platf...@googlegroups.com

> <javascript:> <javascript:>>.
> > >
> > > > To post to this group, send email to
> > > confluent...@googlegroups.com

> > > confluent-platf...@googlegroups.com
> <javascript:>

> > > <https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>
> > <https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>>>.
> > >
> > > --
> > > You received this message because you are subscribed to the
> Google
> > > Groups "Confluent Platform" group.
> > > To unsubscribe from this group and stop receiving emails
> from it,
> > send

> > > an email to confluent-platf...@googlegroups.com
> <javascript:>
> > <javascript:>
> > > <mailto:confluent-platf...@googlegroups.com

> <javascript:>
> > <javascript:>>.
> > > To post to this group, send email to
> confluent...@googlegroups.com
> > <javascript:>

> > <https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>>.
> >
> > --
> > You received this message because you are subscribed to the Google
> > Groups "Confluent Platform" group.
> > To unsubscribe from this group and stop receiving emails from it,
> send

> > an email to confluent-platf...@googlegroups.com
> <javascript:>
> > <mailto:confluent-platf...@googlegroups.com

> <javascript:>>.
> > To post to this group, send email to confluent...@googlegroups.com
> <javascript:>
> > <mailto:confluent...@googlegroups.com <javascript:>>.
> > To view this discussion on the web visit
> >

> https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>
> > For more options, visit https://groups.google.com/d/optout

> <https://groups.google.com/d/optout>.
>
> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send

> an email to confluent-platf...@googlegroups.com
> <mailto:confluent-platf...@googlegroups.com>.

> To post to this group, send email to confluent...@googlegroups.com
> <mailto:confluent...@googlegroups.com>.
> To view this discussion on the web visit

> https://groups.google.com/d/msgid/confluent-platform/aa97468d-24e4-47a6-ab79-3bf56b3d2b73%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/aa97468d-24e4-47a6-ab79-3bf56b3d2b73%40googlegroups.com?utm_medium=email&utm_source=footer>.

signature.asc

vivek sharma

unread,

Feb 9, 2017, 4:40:41 PM2/9/17

to Confluent Platform, da...@confluent.io

Thank you Matthias, Even I should be good with CP 3.1.1 as of now, if I can get it from Market place, at least I can use latest Kafka Streams API with that, right now I am not able to do that with CP 3.0.0 from Azure Market Place !

> > confluent-platform+unsub...@googlegroups.com <javascript:>
> <javascript:>
> > > >
> > <mailto:confluent-platform+unsub...@googlegroups.com

> > > confluent-platform+unsub...@googlegroups.com

> > > an email to confluent-platform+unsub...@googlegroups.com
> <javascript:>
> > <javascript:>
> > > <mailto:confluent-platform+unsub...@googlegroups.com

> <javascript:>
> > <javascript:>>.
> > > To post to this group, send email to
> confluent...@googlegroups.com
> > <javascript:>
> > > <mailto:confluent...@googlegroups.com <javascript:>>.
> > > To view this discussion on the web visit
> > >
> >
> https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com>>
>
> >
> > >
> >
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/e50a2dc0-b63b-48fc-8de7-5087fc395294%40googlegroups.com?utm_medium=email&utm_source=footer>>>.
>
> >
> > > For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>
> > <https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>>.
> >
> > --
> > You received this message because you are subscribed to the Google
> > Groups "Confluent Platform" group.
> > To unsubscribe from this group and stop receiving emails from it,
> send

> > an email to confluent-platform+unsub...@googlegroups.com
> <javascript:>
> > <mailto:confluent-platform+unsub...@googlegroups.com

> <javascript:>>.
> > To post to this group, send email to confluent...@googlegroups.com
> <javascript:>
> > <mailto:confluent...@googlegroups.com <javascript:>>.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com>
>
> >
> <https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com?utm_medium=email&utm_source=footer
> <https://groups.google.com/d/msgid/confluent-platform/60950123-cf45-4f16-972e-be63a2bfaaee%40googlegroups.com?utm_medium=email&utm_source=footer>>.
>
> > For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send

> an email to confluent-platform+unsub...@googlegroups.com
> <mailto:confluent-platform+unsub...@googlegroups.com>.

Reply all

Reply to author

Forward