Kafka task#


Apache Kafka is an open-source stream-processing software platform developed by the Apache Software Foundation. (for more info : https://kafka.apache.org/)
You need to download these jar files and place them in your CrushFTP ▸ plugins ▸ lib folder.
kafka-clients.jar(info)
kafka-streams.jar(info)

Then restart CrushFTP.

Using Kafka task you are able to send a file or a custom topic.

attachments

It is possible to load your own SASL connection parameters with the flag "Load custom client config"

attachments

Config example:
#KafkaTask SASL properties file example

# Kafka server host and port.
bootstrap.servers=192.168.10:9092

# Client id
client.id=MyCrushFTP

# Serializer (Do not change!)
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer

#Max block and timeout
max.block.ms=10000
request.timeout.ms=20000 

#Authentication related settings
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
    username="kafka-username" \
    password="kafka-password" \

Add new attachment

Only authorized users are allowed to upload new attachments.

List of attachments

Kind Attachment Name Size Version Date Modified Author Change note
jar
kafka-clients.jar 1,893.6 kB 1 29-Dec-2020 05:25 krivacsz
jar
kafka-streams.jar 821.8 kB 1 29-Dec-2020 05:25 krivacsz
png
kafka_custom_config.png 214.3 kB 1 04-May-2021 05:03 krivacsz
png
kafka_task.png 79.1 kB 1 04-May-2021 05:03 krivacsz
« This page (revision-17) was last changed on 04-May-2021 05:12 by krivacsz
G’day (anonymous guest)
CrushFTP10 | What's New

Referenced by
LeftMenu

JSPWiki