kafka_send ()

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

描述:

producer发送消息

语法:

kafka_send(fd, [key,] value)

kafka_send(fd, partition, key, value)

备注:

外部库函数,无分区时,参数key可以省略;有分区时,参数partitionkeyvalue都不可以省略。

参数:

fd

连接对象

key

消息的关键字

value

消息的值

partition

分区索引号,以0开始的整数或序列

示例:

 

A

 

1

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

连接kafka server

2

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

keyA100valueapple的消息发送至A1

3

=kafka_send(A1,"apple")

无分区时,可以省略参数key

4

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

 

5

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

有分区时,参数都不能省略

6

=kafka_close(A1)

关闭连接