Kafka+Flink

[Vinaya M S <vi...@gmail.com>]

Hi,

I have a 3 node kafka cluster. In server.properties file of each of them
I'm setting
 advertisedhost.name: to its IP.

I have 4 node flink cluster. In each of kaka's node I'm setting
host.name: to one of link's worker node.

like,

in kafka1:
host.name:  flink-data1IP

in kafka2:
host.name: flink-data2 IP

in kafka3:
host.name: flink-data3 IP

My question is,
In order to connect to kafka how should my conf/producer.yaml look like?

kafka.brokers: ??

zookeeper.servers: ??

kafka.port: 9092
zookeeper.port: 2181

kafka.topic: "xxxx"
kafka.partitions: 1

Thanks,
Vinaya

Re: Kafka+Flink

[Robert Metzger <rm...@apache.org>]

Hi Vinaya,

this blog post explains how to connect Flink and Kafka:
http://data-artisans.com/kafka-flink-a-practical-how-to/

On Thu, Jan 28, 2016 at 1:28 AM, Vinaya M S <vi...@gmail.com> wrote:

> Hi,
>
> I have a 3 node kafka cluster. In server.properties file of each of them
> I'm setting
>  advertisedhost.name: to its IP.
>
> I have 4 node flink cluster. In each of kaka's node I'm setting
> host.name: to one of link's worker node.
>
> like,
>
> in kafka1:
> host.name:  flink-data1IP
>
> in kafka2:
> host.name: flink-data2 IP
>
> in kafka3:
> host.name: flink-data3 IP
>
> My question is,
> In order to connect to kafka how should my conf/producer.yaml look like?
>
> kafka.brokers: ??
>
> zookeeper.servers: ??
>
> kafka.port: 9092
> zookeeper.port: 2181
>
> kafka.topic: "xxxx"
> kafka.partitions: 1
>
> Thanks,
> Vinaya
>
>
>