将Kafka与Netflix导体结合使用
我想知道是否有一种简单的方法来连接Kafka和Netflix导体（而不是SQS）？目前，它似乎只适用于Amazon SQS。此外，似乎只能按任务执行一个操作。有没有办法按任务执行多个操作？
提前感谢，
共有1个答案
要向Netflix Conductor添加Kafka支持，您需要
- 在contribs中创建一个扩展AbstractModule的模块（在server.properties中针对conductor.additional.modules属性添加一个条目）
kafka.producer.bootstrap.servers=host1:port1;host2:port2
kafka.producer.key.serializer=org.apache.kafka.common.serialization.StringSerializer
kafka.producer.value.serializer=org.apache.kafka.common.serialization.StringSerializer
kafka.consumer.bootstrap.servers=host1:port1;host2:port2
kafka.consumer.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
kafka.consumer.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
- 通过更新生成，将kafka库支持添加到项目中。contribs模块的渐变
有关实施，请参阅下面的PR链接（作者：preeth gopalakrishnan）
https://github.com/Netflix/conductor/pull/672
（如果没有找到PR，假设它已合并到master）
-
有没有人使用Netflix Conductor的后端完全不同。我们正在考虑以Azure Cosmos DB作为后端插入导体。
-
https://cloud.spring.io/spring-cloud-static/spring-cloud-stream-binder-kafka/3.0.0.M3/reference/html/spring-cloud-stream-binder-kafka.html#_programming_model显示了一个示例，其中可以使用属性设置输入主题。 现在我想使用依赖注入，例如。 启动应用
-
问题内容： 我在SO上发现了其他几个有关JavaMail API和通过SMTP服务器发送邮件的问题，但是没有一个使用TLS安全性进行讨论。我正在尝试使用JavaMail通过我的工作SMTP邮件服务器向我发送状态更新，但是它需要TLS，而且我在网上找不到任何有关如何使用JavaMail访问需要TLS加密的SMTP服务器的示例。有人能帮忙吗？ 问题答案： 实际上，我们的产品中确实有一些通知代码，如果有
-
我已经阅读了一些关于SaaS/PaaS/IaaS的信息，我在想： 如果我提供了一个SaaS应用程序，我的客户能否使用PaaS开发和部署他自己的应用程序，PaaS将使用一些API与我的SaaS应用程序交互？还是我对云服务的理解有误？
-
问题内容： 谁能给我指出一个完整的示例，而 不是 在App Engine上使用OAuth2和Flask对Google帐户进行身份验证？ 我试图让用户授予对Google日历的访问权限，然后使用该访问权限从日历中检索信息并对其进行进一步处理。我还需要存储并稍后刷新OAuth2令牌。 我看过Google的oauth2client库，可以开始检索授权代码了，但是我从那里有点迷失了。通过查看Google的O
-
问题内容： TextMate似乎使用了我假定的内置Python版本（sys.path不起作用）。您如何配置它以使用3.1？我已经安装了3.1软件包，并且可以将IDLE用于交互式会话，但是现在需要使用TextMate。 谢谢 问题答案： TextMate使用变量的值来查找Python解释器的路径。一个好的解决方案是利用TextMate的能力来定义变量（例如基于每个项目）： 打开一个新的或现有的Tex