t;test");
consumer.subscribe(arrayList);
ConsumerRecords<String, String> poll = consumer.poll(1000);
Iterator<ConsumerRecord<String, String>> iterator = poll.iterator();
while (iterator.hasNext()) {
ConsumerRecord<String, String> next = iterator.next();
System.out.print
/ifwe/bruce
>
> those are more out of the box and can work with but reliable because people
> use them live
>
> On Wed, Apr 20, 2016 at 1:05 AM, Sunny Shah <sunny@gmail.com> wrote:
>
> > Hi Yogesh,
> >
> > You can even use sqllite/leveldb to buffer the data on clie
to engineer this sytem then you can use Apache NiFi, It
> is meant for reliable edge node data ingestion.
>
> Thanks,
> Sunny
>
> On Wed, Apr 20, 2016 at 9:41 AM, Yogesh BG <yogesh...@gmail.com> wrote:
>
> > Hi
> >
> >
> >
> > I have a on
is
available.
Meanwhile I should be able to delete the messages from producer buffer
after some size / some days of interval the connection is not available.
--
Yogesh..BG
Senior Software engineer
Sling Media Pvt. Ltd.
PSS Plaza, #6,
Wind Tunnel Road.
Murghesh Palya,
Banglore - 560 017
Contact
is
available.
Meanwhile I should be able to delete the messages from producer buffer
after some size / some days of interval the connection is not available.
--
Yogesh..BG
Senior Software engineer
Sling Media Pvt. Ltd.
PSS Plaza, #6,
Wind Tunnel Road.
Murghesh Palya,
Banglore - 560 017
Contact
