You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Cdhar B <tr...@gmail.com> on 2015/02/21 14:10:29 UTC

Kafka 0.8.2 New Producer Example

Hi,

Could you please provide some info. on Kafka 0.8.2 new producer example. I
tried but not able to find a complete example. Does anybody has a sample?

Appreciate your quick help.

Thanks,
Cdhar

Re: Kafka 0.8.2 New Producer Example

Posted by Joe Stein <jo...@stealth.ly>.

in scala
https://github.com/stealthly/scala-kafka/blob/master/src/test/scala/KafkaSpec.scala#L146-L168

~ Joe Stein
- - - - - - - - - - - - - - - - -

  http://www.stealth.ly
- - - - - - - - - - - - - - - - -

On Sat, Feb 21, 2015 at 8:10 AM, Cdhar B <tr...@gmail.com> wrote:

> Hi,
>
> Could you please provide some info. on Kafka 0.8.2 new producer example. I
> tried but not able to find a complete example. Does anybody has a sample?
>
> Appreciate your quick help.
>
> Thanks,
> Cdhar
>

Re: Kafka 0.8.2 New Producer Example

Posted by Daniel Wegener <da...@holisticon.de>.

Cdhar B <tr...@...> writes:

> 
> Hi,
> 
> Could you please provide some info. on Kafka 0.8.2 new producer example. 
I
> tried but not able to find a complete example. Does anybody has a sample?
> 
> Appreciate your quick help.
> 
> Thanks,
> Cdhar
> 


Hello Cdhar,

if you are looking for a java example, you could look at 

https://github.com/danielwegener/logback-kafka-
appender/blob/master/src/main/java/com/github/danielwegener/logback/kafka/K
afkaAppenderBase.java#L48

and

https://github.com/danielwegener/logback-kafka-
appender/blob/master/src/main/java/com/github/danielwegener/logback/kafka/d
elivery/BlockingDeliveryStrategy.java

Kind regards
Daniel