我想使用samza,但情况是我们的kafka主题创建是有限的(主题创建应该被审查,并且应该有具体的角色)。那么,对于"job.coordinator.system“,还有其他选择吗?我需要用法介绍。非常感谢!
发布于 2017-04-20 23:34:18
从Samza 0.12.0开始,Samza自动创建3类流:
流,用于为启用了changelog 的任何存储输入流的使用检查点
使用Kafka日志压缩主题是非常常见的,但理论上任何系统实现都可以工作。你甚至可以定义你自己的。
关于Samza流抽象的一些细节可以在这里找到:http://samza.apache.org/learn/documentation/0.12/container/streams.html
https://stackoverflow.com/questions/43514196
复制相似问题