I agree with Dmitry's first comment, it really looks like the paragraph he
points to under "Table" was pasted without edit from the one previously
that pertained to "KStream".
On Sun, Dec 17, 2017 at 5:31 PM, Dmitry Minkovsky
wrote:
> On https://docs.confluent.io/current/streams/developer-guide/
watch some videos from Ewan Cheslack-Postava.
https://www.google.ca/webhp?sourceid=chrome-instant&rlz=1C5CHFA_enCA523CA566&ion=1&espv=2&ie=UTF-8#q=youtube+ewan+Cheslack-Postava&*
On Tue, Feb 28, 2017 at 6:55 AM, VIVEK KUMAR MISHRA 13BIT0066 <
vivekkumar.mishra2...@vit.ac.in> wrote:
> Hi All,
>
>
an email titled
> "confirm unsubscribe from users@kafka.apache.org", which you need to reply
> to in order for the unsubscribe to take effect. Did you folks do that?
>
> On Tue, Aug 30, 2016 at 3:40 PM Philippe Derome
> wrote:
>
> > count me out too! ;-)
> >
>
count me out too! ;-)
On Tue, Aug 30, 2016 at 12:54 PM, Heath Ivie wrote:
> I have done the same several times, but I still get these emails.
>
> -Original Message-
> From: Spencer Owen [mailto:so...@netdocuments.com]
> Sent: Tuesday, August 30, 2016 8:33 AM
> To: users@kafka.apache.org
Did you specify same number of partitions for the two input topics you are
joining? I think that this is usually the first thing people ask to verify
with errors similar to yours.
If you are experimenting with learning some concepts, it is simpler to
always use one partition for your topics.
On 13
gt; 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, but just a
> schema id.
>
> Guozhang
>
>
> On Wed, Jul 6, 2016 at 8:12 PM, Philippe Derome
> wrote:
>
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:
>
;name":"lastName","type":{"type":"string","avro.java.string":"String"}},{"name":"companyName","type":{"type":"string","avro.java.string":"String"}},{"name":"address","type":{"type"
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 anyone with a good u
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
See Keyhole Software blog and particularly John Boardman's presentation of
sample app with responsive web client using WebSockets connecting to a
netty embedded web server that itself uses producer and consumer clients
with a Kafka infrastructure (@johnwboardman). On first look, it seems like
a val
Scala 2.12 requires JDK 8 to take advantage of JVM technology. Forcing
migration to JDK 8 explains to some extent the non rush to release 2.12. I
believe Adriaan Moors has a presentation detailing the 2.12 Scala release.
https://adriaanm.github.io/reveal.js/scala-next.html#/
On 17 Jun 2016 8:35 a.m
That would be very doubtful imho. It is much more adventurous to go latest
Kafka release than to go JDK 8.
On 17 Jun 2016 3:19 a.m., "Ismael Juma" wrote:
> Hi Harsha,
>
> Are you saying that you are aware of many Kafka users still using Java 7
> who would be ready to upgrade to the next Kafka fea
ks for me. Can you please try `./gradlew clean
> jarAll` instead?
>
> Ismael
>
> On Fri, Jun 17, 2016 at 12:23 AM, Philippe Derome
> wrote:
>
> > I will.
> >
> > thanks
> > On 16 Jun 2016 1:30 p.m., "Eno Thereska" wrote:
> >
> > >
g to the JIRA and reopen it?
On Thu, Jun 16, 2016 at 6:49 PM, Ismael Juma wrote:
> Hi Philippe,
>
> Building with Java 8 works for me. Can you please try `./gradlew clean
> jarAll` instead?
>
> Ismael
>
> On Fri, Jun 17, 2016 at 12:23 AM, Philippe Derome
> wrote:
>
&g
I will.
thanks
On 16 Jun 2016 1:30 p.m., "Eno Thereska" wrote:
> Hi Phil,
>
> Feel free to comment on that JIRA and re-open if necessary.
>
> Eno
>
>
> > On 16 Jun 2016, at 17:02, Philippe Derome wrote:
> >
> > The issue had apparently ex
I strongly support motion having difficulty running (Apache Kafka as
opposed to Confluent) Stream examples with JDK 8 today.
On 16 Jun 2016 4:46 p.m., "Ismael Juma" wrote:
> Hi all,
>
> I would like to start a discussion on making Java 8 a minimum requirement
> for Kafka's next feature release (l
The issue had apparently existed and is apparently resolved, but so far it
does not work for me: https://issues.apache.org/jira/browse/KAFKA-2203.
I issue same command as Stevo Slavic with JDK 1.8.0_91:
gradle clean jarAll
java -version
java version "*1.8.0_91*"
Java(TM) SE Runtime Environment
Never mind, "three" is a String, and config.messageSendMaxRetries is Int.
Have you identified where that error string comes from in the code you use
though (Failed to send message after three times)?
On Tue, Jun 14, 2016 at 6:54 AM, Philippe Derome wrote:
> Have you l
Have you looked at this (DefaultEventHandler)?
throw new FailedToSendMessageException("Failed to send messages after " +
config.messageSendMaxRetries + " tries.", null)
On Tue, Jun 14, 2016 at 6:40 AM, Snehalata Nagaje <
snehalata.nag...@harbingergroup.com> wrote:
>
>
> Hi All,
>
>
> I am using
20 matches
Mail list logo
