/
YuriyMB
/
Kafka
Обзор
Документация
Войти
/
YuriyMB
/
Kafka
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
testing/src/main/java/sbp/school/streams/StreamConfig.java
24 строки
811 B
trv
Added examples for theory
10 окт 2025, 22:55
10 окт 2025, 22:55
3c41313
Код
Авторство
О чём код?
package sbp.school.streams; import org.apache.kafka.common.serialization.Serdes; import org.apache.kafka.streams.StreamsConfig; import java.util.Properties; public class StreamConfig { public static final String INPUT_TOPIC = "INPUT_TOPIC"; public static final String OUTPUT_TOPIC = "OUTPUT_TOPIC"; public Properties getProperties() { Properties properties = new Properties(); properties.put(StreamsConfig.APPLICATION_ID_CONFIG, "filter"); properties.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); properties.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName()); properties.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName()); return properties; } }