Skip to content

Latest commit

 

History

History
135 lines (101 loc) · 8.2 KB

File metadata and controls

135 lines (101 loc) · 8.2 KB

Engine-vanilla

Find below the list.


AmqpClientPipelineStream

No description provided.

Class

com.hurence.logisland.engine.vanilla.stream.amqp.AmqpClientPipelineStream

Tags

None.

Properties

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.

allowable-values
Name Description Allowable Values Default Value Sensitive EL
connection.host Connection host name null false false
connection.port Connection port 5672 false false
link.credits Flow control. How many credits for this links. Higher means higher prefetch (prebuffered number of messages 1024 false false
connection.auth.user Connection authenticated user name null false false
connection.auth.password Connection authenticated password null false false
connection.auth.tls.cert Connection TLS public certificate (PEM file path) null false false
connection.auth.tls.key Connection TLS private key (PEM file path) null false false
connection.auth.ca.cert Connection TLS CA cert (PEM file path) null false false
read.topic The input path for any topic to be read from false false
read.topic.serializer The serializer to use com.hurence.logisland.serializer.BsonSerializer (serialize events as bson), com.hurence.logisland.serializer.KryoSerializer (serialize events as binary blocs), com.hurence.logisland.serializer.JsonSerializer (serialize events as json blocs), com.hurence.logisland.serializer.ExtendedJsonSerializer (serialize events as json blocs supporting nested objects/arrays), com.hurence.logisland.serializer.AvroSerializer (serialize events as avro blocs), com.hurence.logisland.serializer.BytesArraySerializer (serialize events as byte arrays), com.hurence.logisland.serializer.StringSerializer (serialize events as string), none (send events as bytes), com.hurence.logisland.serializer.KuraProtobufSerializer (serialize events as Kura protocol buffer) none false false
avro.input.schema The avro schema definition null false false
write.topic The input path for any topic to be written to false false
write.topic.serializer The serializer to use com.hurence.logisland.serializer.BsonSerializer (serialize events as bson), com.hurence.logisland.serializer.KryoSerializer (serialize events as binary blocs), com.hurence.logisland.serializer.JsonSerializer (serialize events as json blocs), com.hurence.logisland.serializer.ExtendedJsonSerializer (serialize events as json blocs supporting nested objects/arrays), com.hurence.logisland.serializer.AvroSerializer (serialize events as avro blocs), com.hurence.logisland.serializer.BytesArraySerializer (serialize events as byte arrays), com.hurence.logisland.serializer.StringSerializer (serialize events as string), none (send events as bytes), com.hurence.logisland.serializer.KuraProtobufSerializer (serialize events as Kura protocol buffer) none false false
avro.output.schema The avro schema definition for the output serialization null false false
container.id AMQP container ID null false false
write.topic.content.type The content type to set in the output message null false false
connection.reconnect.backoff Reconnection delay linear backoff 2.0 false false
connection.reconnect.initial.delay Initial reconnection delay in milliseconds 1000 false false
connection.reconnect.max.delay Maximum reconnection delay in milliseconds 30000 false false

Extra informations

No additional information is provided


KafkaStreamsPipelineStream

No description provided.

Class

com.hurence.logisland.engine.vanilla.stream.kafka.KafkaStreamsPipelineStream

Tags

None.

Properties

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.

Extra informations

No additional information is provided


PlainJavaEngine

No description provided.

Class

com.hurence.logisland.engine.vanilla.PlainJavaEngine

Tags

None.

Properties

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.

allowable-values
Name Description Allowable Values Default Value Sensitive EL
jvm.heap.min Minimum memory the JVM should allocate for its heap null false false
jvm.heap.max Maximum memory the JVM should allocate for its heap null false false

Extra informations

No additional information is provided