Thanks. I'm encountering a strange issue.
If I create messages thru console-producer.sh on a new topic, things work fine. But on the topic that I need to consume, the messages are being produced via the go kafka plugin. On this topic, at first, nothing happens when the stream starts (i.e it doesn't process the messages which are already in there) Then, if I produce new messages, then my exception handler is called with the exception that timestamp is negative. I'm pretty sure I'm on kafka 0.10. I downloaded it 2-3 weeks ago. I'm going to write a new timestamp extractor, but any ideas why nothing happens with the old messages which are in the topic, it only responds if i push new messages to this topic? On Fri, Oct 7, 2016 at 7:25 AM, Matthias J. Sax <matth...@confluent.io> wrote: > -----BEGIN PGP SIGNED MESSAGE----- > Hash: SHA512 > > Sure. > > Just use #print() or #writeAsText() > > > - -Matthias > > On 10/6/16 6:25 PM, Ali Akhtar wrote: > > What the subject says. For dev, it would be a lot easier if > > debugging info can be printed to stdin instead of another topic, > > where it will persist. > > > > Any ideas if this is possible? > > > -----BEGIN PGP SIGNATURE----- > Comment: GPGTools - https://gpgtools.org > > iQIcBAEBCgAGBQJX9weuAAoJECnhiMLycopPtbIP/R2hJgcfOtPqlRqbuQ1590D8 > zznMVi9TPPZM4RiGInuUFpefT3Emwxh0lbkNziEQKh+CmPjFqL6nUqssK+2G4dgf > Aer3s5lMa0gz/AxhOwYi97VjptCGT21zxop5gbgWi4FlNapncHAFiziS5WxDkJgf > LqJR6/isexI5Av5pQQkXvxQ7/S7GWFQKHygrqKJqGP6N5+kFtpPjJrzBie3VLuCN > nMkgInWPFMoLNvLUCHGHIClPJe1Go+/4guXUuy1xDWHjeEHnT26+KnpOlTfuiBU6 > rNWoJqFWUb4je+QVQt/9izCuaBQQhPp4HaH2e5F9DJd72VOjg3e0CB1uRYVf4qCM > zhXhiXXkDKfunxhMHcPFTXITPXClwRxhTJnDuYWOFaMPyrwDeXz3c3hMEaJlNRDe > PyIvsh3OWcA9IxGjsvHETtFK//ujBDn3zh9t/lkQlj36s+h/Sz+NMYMrFh1ipPbR > yd/YwYUNnRp5f8udmWOktUvx1RUc8vjwA8VXCppiIiCLUhMF8HH8lFNRzOgTz+PF > kV//LXSpovfzlPDDfuK1WijgjG1su/IWSpOGBqOM56fke9/xtoY5T5iqYVyvIsDI > I3I4M8xOSZHRm4ye+OX+qa9Cwf4h0/LcdWJkbQT1TgNvYf0dOTZDKsLvcy/tOk/U > 2SXFUX7k+6Es38vhcfXU > =ypHP > -----END PGP SIGNATURE----- >
