小编Asm*_*ean的帖子

相当多的文章描述了实现Kafka Streams的使用,它们输出到新的Kafka主题而不是保存到某种分布式数据库.

这只是一个常见的用例,假设嵌入式db +交互式查询已经足够,或者是否存在一些架构原因,为什么人们希望在再次使用主题之前输出主题以保留它,而不是直接持久化？

我不确定它是否有所作为,但我正在研究的示例的上下文是翻滚时间窗口聚合.

我试图让我的Makefile只在文件发生变化时才重新编译,它对Java目标起着很好的作用,但不适用于JS.报告没有任何错误,但是当我make bundle第二次运行时,它仍然会重新运行所有这些命令.

find ...手动运行的输出似乎产生了预期的结果,没有额外或缺少的线.

JAVA_SRC_DIR := .
JAVA_SOURCES := $(shell find $(JAVA_SRC_DIR) -name '*.java' -o -name '*pom.xml')

JS_SRC_DIR := ./ui-bundle
JS_EXCLUDE := \(node_modules\|coverage\)
JS_SOURCES := $(shell find $(JS_SRC_DIR) -name '*.js' -o -name '*.jsx' -o -name '.babelrc' -o -name 'package.json' | grep -v $(JS_EXCLUDE) | grep -v -e '^$')

bundle: $(JS_SOURCES)
    npm install
    ./node_modules/jest-cli/bin/jest.js --verbose
    ./node_modules/gulp/bin/gulp.js package

service: $(JAVA_SOURCES)
    mvn clean install -pl "!integration"

我猜这与它有关,但是当我试图找到哪些文件make认为已经改变时make -d | grep "\(older\|newer\)"它没有找到任何东西,但make -d最后得出结论:

 Finished prerequisites …