To connect to Kafka, you can refer to the detailed steps in the Document section from the menu.
Step 1: Create a producer.py
file
Step 2: In the file producer.py
, fill in some informations like:
sasl_plain_username and sasl_plain_password are the username and password of the credentials you have created.
topic is the name of the topic you have created and previously set permissions for (allow, write topic).
bootstrap.servers: This is the information of the cluster that the admin has assigned to the user.
Step 3: After setting up the necessary information, open the terminal and run this command:
python .\producer.py
The result should be as follows:
If the output is correct, it means the producer has successfully sent messages to the partitions of the topic.
Step 1: First, create a consumer.py
file
Step 2: In this consumer.py
file, fill in some informations like:
group_name is the name of the group you have created and previously set permissions for (allow, read topic).
sasl_plain_username and sasl_plain_password are the username and password of the credentials you have created.
topic is the name of the topic you have created and previously set permissions for (allow, write topic; allow, read topic).
bootstrap.servers: This is the information of the cluster that the admin has assigned to the user.
Step 3: After setting up the necessary information, open the terminal and run this command:
python .\consumer.py
The result should be as follows: