Skip to content

GitLab

Unverified Commit c3c6a104 authored by Bennett Piater's avatar Bennett Piater
Browse files

disable topic2a

parent cae03ea7
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
kafka-images/watermark/index.js
View file @ c3c6a104
......@@ -36,7 +36,8 @@ async function processImage(filename, data) {
if (err)
return;
writeToKafka("topic2", filename + ".watermarked.jpg", JSON.stringify({data: buffer.toString("base64")}));
writeToKafka("topic2a", filename + ".watermarked.jpg", JSON.stringify({data: buffer.toString("base64")}));
// TODO if not all connectec actions are invoked for all triggers, add an additional topic
// writeToKafka("topic2a", filename + ".watermarked.jpg", JSON.stringify({data: buffer.toString("base64")}));
});
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment