Kafka producers
Введение в Apache Kafka
Mike Metzger
Data Engineering Consultant
Что такое producer?
- Записывает сообщения в топики Kafka
- Иногда называется publisher
- Сообщения от producers сохраняются в Kafka для дальнейшего использования
- Может быть несколько producers
- Producer может писать в один или несколько топиков
Типы producers
- Существует множество видов producers
- Командная строка
kafka-console-producer.sh
- Python
- Java
- Многие другие языки
- Kafka Connect
- Командная строка
kafka-console-producer.sh
- Находится в папке
bin/вместе с другими инструментами Kafkabin/kafka-console-producer.sh
- Имеет несколько параметров командной строки: обязательные и необязательные
- Обязательные параметры:
--bootstrap-server— указывает, какой сервер использовать--bootstrap-server localhost:9092
--topic--topic phishing-sites
- По умолчанию открывает соединение для ввода сообщений
- Для выхода используйте Ctrl-C
- Также можно передавать сообщения через символ
|
Пример
- Интерактивный режим
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic testing
>This is the first message
>This is the second message
>This is the third message
<ctrl+c to exit>
- Неинтерактивный режим
echo "This is the first message" |
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic testing
Давайте потренируемся!
Введение в Apache Kafka
