kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bruno D. Rodrigues" <bruno.rodrig...@litux.org>
Subject Re: KafkaStream bug?
Date Mon, 14 Oct 2013 19:23:52 GMT
Yes it's kind of blocking. It basically tries to consume every message and create a representation
of it, kind of like a List.toString(). Why would that make any sense, I have no idea, just
mentioning that I did do the same mistake trying to get something out of the toString() for
the connection, and getting scared when I stepped inside the code mostly because I have not
much knowledge about scala. And yes it did confuse me to see Eclipse reporting the toString()
as a non-overriden version from Object, but then stepping in via debugger it does enter the
kafka code and shows non-java code that tries that "consume them all". I may be completely
wrong though. 


A 14/10/2013, às 20:05, "hsy541@gmail.com" <hsy541@gmail.com> escreveu:

> I found some weird behavior,
> I follow the exact code example for HighlevelConsumer
> 
> https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example#
> 
> but add one debug line here
> "
>    public void run() {
>        ConsumerIterator<byte[], byte[]> it = m_stream.iterator();
>        while (it.hasNext()){
> 
> * ////////////////////////////////////////////my line
> here//////////////////////////////////////////////////*
> * System.out.println("from the stream" + m_stream); \\This line will be
> blocked. KafkaStream.toString() is a blocking method?????*
> * /////////////////////////////////////////// end of my line
> ///////////////////////////////////////////////////////*
> *
> *
>            System.out.println("Thread " + m_threadNumber + ": " + new
> String(it.next().message()));
> }
>        System.out.println("Shutting down Thread: " + m_threadNumber);
>    }
> "


Mime
View raw message