RE: Kafka UTF 8 encoding problem

2016-11-09 Thread Baris Akgun (Garanti Teknoloji)
ing is in utf-8 in the first place? > What if you pass your string via something like: > > System.out.println( new String( > args[0].getBytes(StandardCharsets.UTF8), > StandardCharsets.UTF8) ) > > – > Best regards, > Radek Gruchalski > ra...@gruchalski.com > > > On November 9, 2

RE: Kafka UTF 8 encoding problem

2016-11-09 Thread Baris Akgun (Garanti Teknoloji)
mething like: > > System.out.println( new String( > args[0].getBytes(StandardCharsets.UTF8), > StandardCharsets.UTF8) ) > > – > Best regards, > Radek Gruchalski > ra...@gruchalski.com > > > On November 9, 2016 at 12:14:03 PM, Baris Akgun (Garanti Teknoloji) ( > barisa...@g

RE: Kafka UTF 8 encoding problem

2016-11-09 Thread Baris Akgun (Garanti Teknoloji)
ing Kafka API, I also try with Kafka CLI and Java kafka api but I always face with same issue. Thanks From: Radoslaw Gruchalski [mailto:ra...@gruchalski.com] Sent: Wednesday, November 9, 2016 1:49 PM To: Baris Akgun (Garanti Teknoloji); users@kafka.apache.org Subject: Re: Kafka UTF 8 encoding pr

Kafka UTF 8 encoding problem

2016-11-09 Thread Baris Akgun (Garanti Teknoloji)
Hi All, We are using Kafka 0,9.0.0 and we want to send our messages to topic in UTF-8 format but when we consume the messages from topic we saw that kafka does not keep the original utf-8 format and we did not see the messages exactly. For example our message that includes turkish characters

Kafka with Flume

2016-09-19 Thread Baris Akgun (Garanti Teknoloji)
Hi, We are using flume with kafka source. Flume gets json messages from kafka topic with given morphline file. If any message that has not well formed with morphline file json structure is added to kafka topic, flume (consumer) always tries to consume that wrong message. When we looked the

Kafka Consumer Problem

2016-04-06 Thread Baris Akgun (Garanti Teknoloji)
Hi, I am trying to consume message from kafka with using web service. For exapmle; when the user call that web service, the all messages from partitions will be read by consumers and web service will returns the kafka messages to user who called it. I used below code for that purpose but