Kafka主题与泉流通道、泉流目的地的区别
打扰一下！我从我的团队那里得到了同样的问题，他们问我Kafka的主题、泉云溪的通道和泉云溪的目的地有什么不同点。我们试图在网上搜索，但没有得到任何线索。
共有1个答案
- Kafka主题如其所言-Kafka主题
- 消息通道实际上是由Spring Integration实现并由Spring Cloud Stream使用的EIP抽象。
- Spring Cloud stream destination-我假设您引用的是
destination绑定属性（例如spring.Cloud.stream.bindings.input.destination=MyDestination)。如果是这样，它只是一个映射指令，将特定的通道映射到特定的代理目的地。在上面的示例中，假设您使用的是Kafka，则指示框架将MyDestinationKafka主题桥接到Input消息通道。
简而言之，Spring Cloud Stream current binder实现(Rabb、kafka等）是消息通道绑定器--也就是说，它们将外部目的地（如rabbit队列、kafka主题）绑定到内部消息通道，确保在编写消息处理程序时采用一致的方法。
-
我想使用spring cloud stream framework创建一个kafkaendpoint，它将有一个http post api到。如何动态更改属性 我可以使用实现来实现上述功能，但不知道是否有可能在Spring中开发此功能。
-
我有一个spring云应用程序充当涡轮服务器和Hystrix仪表盘。它有一个Eureka客户端，仪表板出现了，可以看到一个单独的Hystrix流，但我没有得到任何涡轮流。 这是application.yml： 如果我在Turbin/Dashboard应用程序启动时查看日志，它会发现我的Hystrix服务正常： 如果我撞上涡轮流 我得到： 看起来涡轮程序发现了两个项目-通过Eureka的服务和他们的
-
我有一个kafka流应用程序，它在其中使用stateStore（由RocksDB支持）。 stream thread所做的只是从kafka主题获取数据并将数据放入State Store。（还有其他线程从statestore读取数据并进行业务逻辑处理）。 我观察到它创造了一个新的Kafka主题“变化日志”，因为Statestore。 但我没有明白“变化”Kafka话题有什么用处？ 为什么需要它（更改
-
作为几千年中华文明的见证，浩瀚传统文化传承的载体，汉字是让我们每一个中国人引以为豪的东方文明的标志之一。我们的祖先创造汉字，书写汉字，利用汉字和 汉语的无穷魅力创造出让人叹为观止的文学，艺术。而今天进入了计算机时代的我们，虽然不再象古人一样手持毛笔，批著简帛，但我们的生活仍然无时无刻离不开 汉字。 可以毫不夸张的讲，汉字①是世界上最为复杂和庞大的符号系统之一。早在殷商时期，我们的先人就创造出了数目
-
我有一些关于Kafka主题分区->spark流媒体资源利用的用例，我想更清楚地说明这些用例。 我使用spark独立模式，所以我只有“执行者总数”和“执行者内存”的设置。据我所知并根据文档，将并行性引入Spark streaming的方法是使用分区的Kafka主题->RDD将具有与Kafka相同数量的分区，当我使用spark-kafka直接流集成时。 因此，如果我在主题中有一个分区和一个执行器核心，
-
我正在尝试设置一个安全的Kafka集群，但在ACL方面遇到了一些困难。 Kafka流的汇流安全指南（https://docs.Confluent.io/current/Streams/developer-guide/security.html）只说明必须将集群创建ACL交给主体...但它没有说任何关于如何实际处理内部话题的内容。 通过研究和实验，我确定（对于Kafka版本1.0.0): 通配符不能