Java byte[] to String not working when assigned to String

Question

I am using Kafka and following along with this tutorial (https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example)

After some tweaks, the code compiles and everything runs like it should. my problem is that I am trying to utilize an array of bytes that the Kafka server sends me to do some processing. If I use the default code, everything works fine and the byte array gets converted to a String and displayed on my screen. If I try to read the byte array and assign it to a String so that I can display it to the screen and then parse it nothing happens.

it.next().message() returns a byte array

Default code:

ConsumerIterator<byte[], byte[]> it = m_stream.iterator();
while (it.hasNext())
    System.out.println("Thread " + m_threadNumber + ": " + new String(it.next().message()));

My Code that breaks:

 ConsumerIterator<byte[], byte[]> it = m_stream.iterator();
 String msg= "";
 while (it.hasNext())
    msg = new String(it.next().message());
    System.out.println("Thread " + m_threadNumber + ": " + msg);

Can anybody tell me why I cannot assign the byte array to my String? And of course how to fix my glitch?

I've taken a look at:

Java byte to string

Convert byte to string in Java

converting byte[] to string

but none of them seem to apply, they all try to assign the byte array to the String as the String is initialized and I cannot do that here.

OK well there it is I have been sitting at my desk too long. The default code only executes that one line so I didn't need the brackets. When I added the extra line I violated that assumption of a while one liner. Credit to @Juan as having the first answer when I checked in (and honestly I owe you an apology because I scoffed at it. Sorry for the ill thoughts about your reply) I'll accept it as soon as SO will let me — Semicolons and Duct Tape
– Semicolons and Duct Tape, Commented Jul 24, 2015 at 16:25

Juan · Accepted Answer · 2015-07-24 16:22:01Z

4

You are missing the curly brackets so your println is only being executed the last time. Try this:

ConsumerIterator<byte[], byte[]> it = m_stream.iterator();
String msg= "";
while (it.hasNext())
{
   msg = new String(it.next().message());
   System.out.println("Thread " + m_threadNumber + ": " + msg);
}

answered Jul 24, 2015 at 16:22

Juan

3,70323 silver badges34 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Seelenvirtuose · Accepted Answer · 2015-07-24 16:22:18Z

Your code is failing because you did not enclose your code block in braces. Adjusting your code reveals:

ConsumerIterator<byte[], byte[]> it = m_stream.iterator();
while (it.hasNext()) { // <- here
    String msg = new String(it.next().message());
    System.out.println("Thread " + m_threadNumber + ": " + msg);
} // <- and here

In fact, with these braces this code snippet is equivalent to your first code snippet.

By the way: No need to declare the variable msg outside the loop.

Muhammad Faisal · Accepted Answer · 2015-07-24 16:42:44Z

0

Just put curly braces while loop block.

while (it.hasNext()){msg = new String(it.next().message());
System.out.println("Thread " + m_threadNumber + ": " + msg);}

answered Jul 24, 2015 at 16:42

Muhammad Faisal

1

Collectives™ on Stack Overflow

Java byte[] to String not working when assigned to String

3 Answers 3

Comments

Comments

Comments

Linked

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

Comments

Comments

Comments

Linked

Related