Kafka 消息是采用 Pull 模式，还是 Push 模式？
Kafka 最初考虑的问题是，customer 应该从 brokes 拉取消息还是 brokers 将消息推送到consumer，也就是 pull 还 push。在这方面，Kafka 遵循了一种大部分消息系统共同的传统的设计：producer 将消息推送到 broker，consumer 从 broker 拉取消息。一些消息系统比如 Scribe 和 Apache Flume 采用了 push 模式，将消息推送到下游的consumer。这样做有好处也有坏处：由 broker 决定消息推送的速率，对于不同消费速率的consumer 就不太好处理了。消息系统都致力于让 consumer 以最大的速率最快速的消费消息，但不幸的是，push 模式下，当 broker 推送的速率远大于 consumer 消费的速率时，consumer 恐怕就要崩溃了。最终 Kafka 还是选取了传统的pull 模式。Pull 模式的另外一个好处是 consumer 可以自主决定是否批量的从 broker 拉取数据。Push模式必须在不知道下游 consumer 消费能力和消费策略的情况下决定是立即推送每条消息还是缓存之后批量推送。如果为了避免 consumer 崩溃而采用较低的推送速率，将可能导致一次只推送较少的消息而造成浪费。Pull 模式下，consumer 就可以根据自己的消费能力去决定这些策略。Pull 有个缺点是，如果 broker 没有可供消费的消息，将导致 consumer 不断在循环中轮询，直到新消息到 t 达。为了避免这点，Kafka 有个参数可以让 consumer 阻塞知道新消息到达(当然也可以阻塞知道消息的数量达到某个特定的量这样就可以批量发送）
-
本文向大家介绍Kafka消息是采用Pull模式，还是Push模式？相关面试题，主要包含被问及Kafka消息是采用Pull模式，还是Push模式？时的应答技巧和注意事项，需要的朋友参考一下 Kafka最初考虑的问题是，customer应该从brokes拉取消息还是brokers将消息推送到consumer，也就是pull还push。在这方面，Kafka遵循了一种大部分消息系统共同的传统的设计：pro
-
我是Kafka新手，我正在使用Kafka1.0。 我使用拉取模式读取kafka消息，也就是说，我定期查看Kafka主题以获取新消息，但我没有将偏移量写回Kafka。 我会问Kafka如何知道我消耗了哪些偏移量，或者Kafka记住进度的机制是什么（Kafka偏移量）
-
问题内容： 我已经在网上看到了一些讨论，其中有一个logback.xml文件具有XML模式或DTD至少对IDEA或Eclipse这样的IDE具有最基本的验证和自动完成功能有多大的作用，但我从未见过任何解决方案。 你是否？ 问题答案： 根据文档，它不受正式支持，但是有一个独立的项目提供Logback的架构 但是，由于Logback配置具有极大的灵活性，因此Schema无法支持所有可能的配置选项。
-
我用的是Kafka0.8.2。正如文件所说： batch.num.messages指定： 使用异步模式时要在一批中发送的消息数。生产者将等待该数量的消息准备好发送或排队。缓冲器已达到最大毫秒。 和请求。必修的。acks控制代理对请求的确认。 我想知道Kafka经纪人如何发送这个确认，它是否发送批次确认字符，还是每个单独的消息？
-
参与GitHub中的项目开发，最常用和推荐的首选方式是“Fork + Pull”模式。在“Fork + Pull”模式下，项目参与者不必向项目创建者申请提交权限，而是在自己的托管空间下建立项目的派生（Fork）。 如果一个开源项目派生出另外的项目，通常意味着项目的分裂和开发团队的削弱，而GitHub中的项目派生则不会，而且正好相反，GitHub中的项目派生是项目壮大的体现。所有的派生项目都会有链接
-
我正在实现一个生成Kafka消息的过程，每个消息都应该有由模式注册表验证的模式。为了开发，我使用docker运行kafka和模式注册表，我的模式由模式注册表ui进行注册。 看起来我的模式没有被验证或者我缺少一些配置。我的生产者类有以下代码： 大多数时候，我会收到一个错误，如“Schema not found”，当没有引发此异常时，我的消息不会被验证，它只是将消息发送到另一个主题。 是否缺少任何类型