当前位置: 首页 > 知识库问答 >
问题:

Apache Kafka和Spring Cloud Stream上的Kafka流有什么区别?

岑俊明
2023-03-14

在Spring云网站(https://spring.io/projects/spring-cloud-stream),列出了要使用的活页夹选项。我们有阿帕奇Kafka和Kafka流选项。

  1. 他们之间有什么区别

共有1个答案

马寒
2023-03-14

Apache Kafka binder用于基本Kafka客户端使用消费者/生产者api,

kafka Stream binder建立在基础apache kafka binder之上,并增加了使用kafka stream api的能力,

Kafka streams api是一种轻量级代码库,它为您提供了将数据从Kafka中的主题操作到Kafka中其他主题的功能,允许您转换、增强、过滤、连接、聚合等。。。

Apache Kafka Binder实现将每个目标映射到Apache Kafka主题。消费者组直接映射到相同的Apache Kafka概念。分区也直接映射到Apache Kafka分区。

活页夹当前使用Apache Kafka Kafka客户端版本2.3.1。此客户端可以与较旧的代理进行通信(请参阅Kafka文档),但某些功能可能不可用。例如,版本早于0.11。x、 x,不支持本机标头。此外,0.11。x、 x不支持autoAddPartitions属性

https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.3/reference/html/spring-cloud-stream-binder-kafka.html#_apache_kafka_binder

Spring Cloud Stream包括一个为Apache Kafka Streams绑定专门设计的绑定器实现。通过这种本机集成,Spring云流“处理器”应用程序可以在核心业务逻辑中直接使用Apache Kafka Streams API。

Kafka Streams binder的实现建立在Spring for Apache Kafka项目提供的基础之上。

Kafka Streams binder为Kafka Streams中的三种主要类型提供绑定功能—KStream、KTable和GlobalKTable。

Kafka Streams应用程序通常遵循这样一种模型:从入站主题读取记录,应用业务逻辑,然后将转换后的记录写入出站主题。或者,也可以定义没有出站目的地的处理器应用程序。

https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.3/reference/html/spring-cloud-stream-binder-kafka.html#_kafka_streams_binder

 类似资料:
  • 我用经纪人ID的20、21、22创建了3个Kafka经纪人设置。然后我创建了这个主题: 其结果是: 当生产者向主题zeta发送消息“Hello World”时,Kafka首先将消息写入哪个分区? 如果我有8个用户在他们自己的进程或线程中并行地运行,并订阅了zeta主题,那么Kafka如何分配分区或代理来并行地为这些用户服务?

  • 我发现maven repo中有几个Kafka。 阿帕奇的maven回购协议中有两个Kafka。https://mvnrepository.com/artifact/org.apache.kafka/kafka https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients 它们都可以从kafka服务器生成Mesg并消耗msg。 我

  • 问题内容: 所述流文档状态双工流 “是同时实现可读写接口流”和变换流 “是双相流其中输出以某种方式从输入计算”。不幸的是,文档没有描述Transplex流在Duplex流之外提供的内容。 两者之间有什么区别吗?您什么时候可以使用另一个? 问题答案: 可以将双工流视为具有可写流的可读流。两者都是独立的,每个都有独立的内部缓冲区。读写事件独立发生。 转换流是双工的,其中读写以因果关系进行。双工流的端点

  • 我已经在kafka上工作了相当长的六个月,我对用户延迟和存储到主题分区中的数据有一些疑问。 问题1:最初,当我开始阅读Kafka并了解如何使用Kafka的功能时,我被教导说,一个只有一部分和一个复制因子的主题会创造奇迹。经过相当长的六个月的工作,将我的项目迁移到live之后,使用我的主题消息的消费者开始给我一个延迟。我阅读了许多关于消费者延迟的堆栈溢出答案,得出结论,如果我增加某个主题的分区和复制

  • 从spring-docs中,我可以看到 但是如果监听器提交偏移量,到底有什么不同。对于模式,还需要执行哪些其他步骤

  • 问题内容: 它们都在释放鼠标按钮后被举起一次,并且都可以在JRadioButton上获得所有可用的信息,对吗?有什么区别吗? 问题答案: 一个,就会通知当过按钮的状态改变时,用户是否通过与按钮(通过相互作用或编程方法)。 另一方面,当用户与按钮互动时会被调用(但可以通过方法进行编程模拟)。 请注意,与按钮交互(例如单击或击中空格键)的用户也将更改按钮的状态,并引发项目事件和动作事件。通常,您将要定