From f0a7a05b2e2295e01d4ecbf63d35b671ed5dbc54 Mon Sep 17 00:00:00 2001
From: Dmitry Dementev <me@dementev.space>
Date: Thu, 8 Jan 2026 15:22:54 +0300
Subject: [PATCH] =?UTF-8?q?=D0=9F=D1=80=D0=B8=D0=BC=D0=B5=D1=80=D1=8B=20?=
 =?UTF-8?q?=D0=B8=D1=81=D0=BF=D0=BE=D0=BB=D1=8C=D0=B7=D0=BE=D0=B2=D0=B0?=
 =?UTF-8?q?=D0=BD=D0=B8=D1=8F=20Kafka?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 README.md | 23 ++++++++++++++++++-----
 1 file changed, 18 insertions(+), 5 deletions(-)

diff --git a/README.md b/README.md
index 76b6f1e..a6551cc 100644
--- a/README.md
+++ b/README.md
@@ -137,27 +137,40 @@ select * from ods.samplekafka2postgres order by id desc limit 10;
 
 #### Базовые команды CLI (опционально)
 
-Все команды выполняются через `docker compose exec kafka`:
+> ⚠️ **Важно:** В Apache Kafka 3.8.0 скрипты находятся в `/opt/kafka/bin/`, поэтому нужно указывать полный путь.
 
 **Чтение сообщений:**
 ```sh
-docker compose exec kafka kafka-console-consumer.sh \
+docker compose exec kafka /opt/kafka/bin/kafka-console-consumer.sh \
   --bootstrap-server localhost:9092 \
   --topic Sample2Kafka \
   --from-beginning
 ```
 
 **Запись сообщений:**
+
+**Интерактивный режим** (ввод сообщений вручную):
 ```sh
-docker compose exec kafka kafka-console-producer.sh \
+docker compose exec kafka /opt/kafka/bin/kafka-console-producer.sh \
   --bootstrap-server localhost:9092 \
   --topic Sample2Kafka
 ```
-Пример JSON-сообщения: `{"dttm": 1704698992000, "txt": "Тестовое сообщение"}`
+После запуска введите сообщение и нажмите Enter. Нажмите `Ctrl+C` для выхода.
+
+**Отправка одной командой** (через `echo` и pipe):
+```sh
+echo '{"dttm": 1704698992000, "txt": "Тестовое сообщение"}' | \
+  docker compose exec -T kafka /opt/kafka/bin/kafka-console-producer.sh \
+  --bootstrap-server localhost:9092 \
+  --topic Sample2Kafka
+```
+> 💡 **Примечание:** Флаг `-T` отключает TTY, что позволяет использовать pipe.
 
 **Просмотр списка топиков:**
 ```sh
-docker compose exec kafka kafka-topics.sh --bootstrap-server localhost:9092 --list
+docker compose exec kafka /opt/kafka/bin/kafka-topics.sh \
+  --bootstrap-server localhost:9092 \
+  --list
 ```
 
 ## Примеры flow (шаблоны)