View Attach (4) Info

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 05-Dec-2023 05:32 krivacsz
jar
 kafka-streams.jar 821.8 kB 1 05-Dec-2023 05:32 krivacsz
png
 kafka_custom_config.png 214.3 kB 1 05-Dec-2023 05:32 krivacsz
png
 kafka_task.png 79.1 kB 1 05-Dec-2023 05:32 krivacsz

This page (revision-18) was last changed on 28-May-2024 07:42 by krivacsz

This page was created on 05-Dec-2023 05:32 by krivacsz

Only authorized users are allowed to rename pages.

Only authorized users are allowed to delete pages.

Difference between version and

At line 3 changed one line
Apache Kafka is an open-source stream-processing software platform developed by the Apache Software Foundation, written in Scala and Java.
__Apache Kafka__ is an open-source stream-processing software platform developed by the Apache Software Foundation.
At line 5 changed one line
You need to download this jar file and place it in your CrushFTP ▸ plugins ▸ lib folder. [kafka-clients.jar] and [kafka-streams.jar]\\
You need to download these jar files and place them in your CrushFTP ▸ plugins ▸ lib folder.\\
[kafka-clients.jar]\\
[kafka-streams.jar]\\
At line 9 added 36 lines
Then restart CrushFTP.\\
\\
Using Kafka task you are able to send a file or a custom topic.\\
\\
[attachments|kafka_task.png]\\
\\
It is possible to load your own SASL connection parameters with the flag "Load custom client config"\\
\\
[attachments|kafka_custom_config.png]\\
\\
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";
}}}
Version Date Modified Size Author Changes ... Change note
18 28-May-2024 07:42 1.293 kB krivacsz to previous
17 05-Dec-2023 05:32 1.294 kB krivacsz to previous | to last
16 05-Dec-2023 05:32 1.296 kB krivacsz to previous | to last
15 05-Dec-2023 05:32 0.576 kB krivacsz to previous | to last
14 05-Dec-2023 05:32 0.575 kB krivacsz to previous | to last
13 05-Dec-2023 05:32 0.468 kB krivacsz to previous | to last
12 05-Dec-2023 05:32 0.47 kB krivacsz to previous | to last
11 05-Dec-2023 05:32 0.397 kB krivacsz to previous | to last
10 05-Dec-2023 05:32 0.384 kB krivacsz to previous | to last
9 05-Dec-2023 05:32 0.373 kB krivacsz to previous | to last
8 05-Dec-2023 05:32 0.331 kB Ben Spink to previous | to last
7 05-Dec-2023 05:32 0.325 kB krivacsz to previous | to last
6 05-Dec-2023 05:32 0.352 kB krivacsz to previous | to last
5 05-Dec-2023 05:32 0.348 kB krivacsz to previous | to last
4 05-Dec-2023 05:32 0.159 kB krivacsz to previous | to last
3 05-Dec-2023 05:32 0.159 kB krivacsz to previous | to last
2 05-Dec-2023 05:32 0.135 kB krivacsz to previous | to last
1 05-Dec-2023 05:32 0.014 kB krivacsz to last
« This page (revision-18) was last changed on 28-May-2024 07:42 by krivacsz
G’day (anonymous guest)
CrushFTP11 | What's New

Referenced by
LeftMenu

JSPWiki