/
YuriyMB
/
Kafka
Обзор
Документация
Войти
/
YuriyMB
/
Kafka
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
testing/src/main/java/sbp/school/producers/DemoProducer.java
21 строка
610 B
trv
Added examples for theory
10 окт 2025, 22:55
10 окт 2025, 22:55
3c41313
Код
Авторство
О чём код?
package sbp.school.producers; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.producer.RecordMetadata; import java.util.concurrent.Future; public class DemoProducer { private final Producer<String, String> producer; public DemoProducer(Producer<String, String> producer) { this.producer = producer; } public Future<RecordMetadata> send(String key, String value) { ProducerRecord record = new ProducerRecord("test-topic", key, value); return producer.send(record); } }