Как процессор потокового процессора (API низкого уровня) получает данные из темы?
Я просто добавляю небольшие детали:
new FileWriter("outfilename", true)
2.nd (true) - это функция (или, интерфейс), называемая appendable ( http://docs.oracle.com/ JavaSE / 7 / документы / API / Java / языки / Appendable.html [/ д0]). Он отвечает за возможность добавления некоторого контента в конец конкретного файла / потока. Этот интерфейс реализован с Java 1.5. Каждый объект (например, BufferedWriter, CharArrayWriter, CharBuffer, FileWriter, FilterWriter, LogStream, OutputStreamWriter, PipedWriter, PrintStream, PrintWriter, StringBuffer, StringBuilder, StringWriter, Writer) с этим интерфейсом может использоваться для добавления контента В других слова, вы можете добавить некоторый контент в свой gzip-файл или какой-то http-процесс
2 ответа
topology.addSource("SOURCE", "source-topic");
Над «ИСТОЧНИК» просто имя. Вы можете обратиться к классу Topology здесь для более подробной информации.
Как это работает внутри - Когда создается топология, вам нужно определить источник, приемник и процессор, используя следующие методы:
addSource(), addSink() и addProcessor()
В методе streams.start() он вызывает обработку топологии.
Топология начинается с исходного узла для получения данных от Kafka, затем содержит группу процессорных узлов для выполнения преобразований и, наконец, заканчивается узлом приемника для записи преобразованных данных в Kafka.
addSource() создаст исходный узел в вашей топологии. Исходный узел потребляет записи из указанной темы и передает их следующим узлам в топологии. Это не делает никакой другой логики. Под прикрытием исходный узел запустит Потребителя Kafka, чтобы получить записи.
API Kafka Streams позволяет вам сосредоточиться на своей логике (в процессорах) вместо того, чтобы иметь дело с потребителями и производителями.