kafka_send ()

阅读(36) 标签: 发送消息, 索引,

描述:

producer发送消息

语法:

kafka_send(fd, [key,] value)

kafka_send(fd, partition, key, value)

备注:

外部库函数,producer发送消息,根据服务器配置。支持单机模式或群集模式

单机模式时,参数key可以省略;群集模式时,参数partitionkeyvalue都不可以省略。

参数:

fd

consumer对象

key

消息的关键字

value

消息的值

partition

群集下的分区索引号,以0开始的整数

示例:

 

A

 

1

=kafka_open("D://kafka.properties";"topic-test")

连接kafka server

2

=kafka_send(A1, "A100","apple")

keyA100/valueapple的消息发送至A1

3

=kafka_send(A1,"apple")

单机模式时省略参数key

4

=kafka_open@c(file("D://kafka.properties");"topic-test")

 

5

=kafka_send(A1,1, "A100","apple")

群集模式,参数不能省略

6

=kafka_close(A1)

关闭连接