Re: Connector for REST End Point

2017-04-10 Thread Archit Mittal
nstance though. > > Regards, > Chesnay > > > On 10.04.2017 09:50, Archit Mittal wrote: > > Hi > > Any suggestions regarding this. > > Thanks > Archit > > On Thu, Apr 6, 2017 at 2:52 PM, Archit Mittal wrote: > >> Hi Chesnay >> >> I have

Re: Connector for REST End Point

2017-04-10 Thread Archit Mittal
Hi Any suggestions regarding this. Thanks Archit On Thu, Apr 6, 2017 at 2:52 PM, Archit Mittal wrote: > Hi Chesnay > > I have a REST Api that listens to events that come through Kafka but i > dont have access to that Kafka . Can I write a connector that consumes > events throu

Re: Connector for REST End Point

2017-04-06 Thread Archit Mittal
tion, I'm really not sure what you mean. > :( > > Regards, > Chesnay > > > On 06.04.2017 09:40, Archit Mittal wrote: > >> Hi >> >> Can we write a custom connector listening to a REST Api end point in >> Flink >> >> Thanks >> Archit >> > >

Connector for REST End Point

2017-04-06 Thread Archit Mittal
Hi Can we write a custom connector listening to a REST Api end point in Flink Thanks Archit

Re: Doubt Regarding producing to kafka using flink

2017-04-03 Thread Archit Mittal
> <https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/event_timestamps_watermarks.html> > [2] https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/event_ > timestamp_extractors.html > > On April 2, 2017 at 6:38:13 PM, Archit Mittal (marchi...@gmail.com) wrote: &

Doubt Regarding producing to kafka using flink

2017-04-02 Thread Archit Mittal
Hi I am using flink-connector-kafka-0.10_2.10 while producing i am getting error as java.lang.IllegalArgumentException:* Invalid timestamp -9223372036854775808* at org.apache.kafka.clients.producer.ProducerRecord.(ProducerRecord.java:60) ~[kafka-clients-0.10.0.1.jar:na] at org.apache.flink.stre