I just resolved the fix I needed before having time to see your reply. I
took all references to JsonPOJO and Jackson JSON dependencies and am using
for VALUE_SERDE_CONFIG SpecificAvroSerde and it works well. Indeed I had
not planned to embed the schema info in each message as this would be
tedious
The examples code in AK repo uses JSON as the serde, whereas the examples
in CP repo used Avro, with the embedded schema. These two are different
serde schemes.
Using a schema registry for Avro / etc would be a better approach to you,
since it does not require each message to embed the schema info
I think I should simply follow Kafka The Definitive Guide Chapter 3 for a
good Avro producer example instead. It does not introduce some Jackson JSON
layer and still provides the type safety using POJO generated classes from
Avro.
On Wed, Jul 6, 2016 at 9:20 PM, Philippe Derome wrote:
> The type
The typed version of the example (PageViewTypedDemo) is what represents
some difficulty for someone new to Kafka (or CP3). *I think it would be
easier/quicker to complete the documentation of that example than to answer
my questions below*
I am reusing the same JsonPOJOSerializer and JsonPOJOD
yes, it's a very similar example and I am interested in the Kafka one for
the serialization aspect of it, which is a bit richer than on Confluent's...
On Wed, Jul 6, 2016 at 5:35 AM, Michael Noll wrote:
> Correction: Just realized that I misread your message. You are indeed
> referring to the
Correction: Just realized that I misread your message. You are indeed
referring to the code examples in Apache Kafka. ;-)
On Wed, Jul 6, 2016 at 11:35 AM, Michael Noll wrote:
> Phil,
>
> I suggest to ask this question in the Confluent Platform mailing list
> because you're referring to code un
Phil,
I suggest to ask this question in the Confluent Platform mailing list
because you're referring to code under
https://github.com/confluentinc/examples (i.e. code that is not part of the
Apache Kafka project).
Best,
Michael
On Tue, Jul 5, 2016 at 5:34 PM, Philippe Derome wrote:
> Would an
Would anyone with a good understanding of serialization be available to
enhance documentation of the Apache Streams examples? I mean specifically:
PageViewTypedDemo, PageViewUntypedDemo in package org
.apache.kafka.streams.examples.pageview
I'd be happy to run them with Confluent Platform 3 produc
