Write Kafka Topic

Synopsis

This operator sends all examples of an ExampleSet as messages to a Kafka topic.

Description

它可以发送l examples directly after each other, or can wait a specified amount of time between each message. The examples can be either written as a plain string or as a JSON formatted message.

Input

connection

The connection to the Kafka server, to where the messages are send.

example set

The input ExampleSet which should be pushed to the Kafka topic

Output

out

The unchanged ExampleSet is passed through.

Parameters

Kafka topic

The name of the Kafka topic to which should be send.

Update topics

Try to retrieve a list of available topics from server.

Bulk sending

Should all messages be send directly? If true, each example will still be send as an individual message, but directly after each other. If false there will be a delay specified by the "message interval" parameter.

Message interval

Delay between the sending of each example in milliseconds.

Message format

The format of the message send. It will be either a JSON format string with the attribute names and values or a simple string that only contains the attribute values.

属性分离器

If the message format is a single string, this is the separator between the attributes.