我想知道是否有一种简单的方法来连接Kafka和Netflix Conductor(而不是SQS)?目前看来,它似乎只能与Amazon SQS配合工作。此外,每个任务似乎只能执行一个操作。是否有一种方法可以通过一个任务执行多个操作?
提前致谢。
我想知道是否有一种简单的方法来连接Kafka和Netflix Conductor(而不是SQS)?目前看来,它似乎只能与Amazon SQS配合工作。此外,每个任务似乎只能执行一个操作。是否有一种方法可以通过一个任务执行多个操作?
提前致谢。
为了将Kafka支持添加到Netflix Conductor中,您需要:
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
请参考以下PR链接进行实现(作者为preeth-gopalakrishnan)
https://github.com/Netflix/conductor/pull/672
(如果你找不到PR,请假设它已合并到主分支)