《中邮消费金融有限公司》专题

我正在尝试使用Kafka-Python编写一个消费者，以确保精确的once语义。分区中的消息是使用事务感知生成器生成的。我从Kafka文档中了解到，我应该将指定为，这样它将只读取提交的消息。问题是，我在Python客户机的文档中没有看到关于如何指定的任何地方。关于如何让我的消费者只阅读提交的消息，有什么想法吗？ 预期结果：只需获取transation committed消息实际结果：使用者甚至读取

我正在使用带有KafkaListener注释的spring kafka v2.5.2。 在运行时，我希望能够向消费者发送停止消费的信号。 我看到了autoStartup参数，但它似乎只对初始化有效，之后无法更改。 我看到了KafkaListenerEndpointRegistry的methode close（）。。。 你有什么建议吗？ 提前谢谢。

如何使用

我正在尝试运行一个简单的Spring Boot Kafka应用程序，但我无法使其工作。我遵循了各种教程，现在我正在实现这个教程，但当我启动应用程序时，会发生以下情况： 我可以在控制台中写入，但消费者没有收到任何消息。 这是我的SpringApplication类： application.yml： 消费者类、生产者类及其配置类与教程中所写的相同。< br >在我的server.properties

下面是我们设置的简化/示意图拓扑 每个节点（服务器）都是一个独立的（无集群）jboss应用服务器(Jboss-as7)，包括消息传递服务器。 消息传递服务器部署许多JMS队列。 每个任务服务器为每个队列部署一个MDB，每个队列有许多使用者。 所有消息生产者使用相同的入站适配器，所有消息使用者使用相同的出站适配器。事实上，所有前端节点都是完全相同的（与所有服务器节点相同，配置相同，部署的工件相同）。

我在一台Windows主机上安装了两个Kafka 2.1.0代理。默认复制因子设置为2。所有其他设置均为默认设置。 networkClient:[Consumer ClientID=Consumer-1,GroupID=SOUT]无法建立到节点-2(/192.168.0.1:19092)的连接。代理可能不可用。 消费者： 一个制作人：

两轮面试官都非常nice，攒个人品~ 更新，10.17已二面 更新，10.21hr面完成，hr小姐姐很耐心！期待offer 更新，10.29已oc base 武汉 一面： 1、java基础知识，常用的List有哪些，具体讲一下实现和线程安全的做法 2、HashMap 3、copyonwriteList 4、cow缺点 5、讲一下反射，具体应用场景 6、mysql的一些东西，大概两三个问题忘记了 7

一面半个小时，面试官是个小哥哥，声音超好听，态度真的nice，面试体验感拉满，就是我自己太菜了，一些回答不上来，还有一些是面试官的引导下答出来的，我好菜，问了好多浏览器渲染，跨域，还问了计网的一些问题#面试#

1.自我介绍 2.ts泛型，interface和type区别 3.vue组件什么情况下会重新渲染，怎么让一个组件刷新，什么情况下会用到nextick 4.dispaly设置none会引起什么，渲染原理，dom树和渲染树是一一对应的么 5.vue2在设计思路上与vue3有什么区别 6路由原理 7.观察者模式和订阅者模式及区别 8.怎么监测前端性能，有哪些指标 9.前端安全，怎么防范，jwt鉴权，角色

1.自我介绍 2.定位方式 3.三栏布局 4.flex布局，概念，属性，给了个场景题让用flex布局实现 5.跨域 6.浏览器安全 7.重排重绘 8.性能优化方式 9.事件循环，又给了两道看代码说输出 10.三数之和说思路，分析时间复杂度 11.智力题，倒水问题 12.反问，下机

主要内容：1 并发消费重试,1.1 失败重试,1.2 超时重试,2 顺序消费重试,2.1 失败重试,2.2 超时重试,3 broker处理回退请求,3.1 asyncConsumerSendMsgBack处理回退请求,3.2 handleRetryAndDLQ处理重试和死信消息基于RocketMQ release-4.9.3，深入的介绍了DefaultMQPushConsumer消费者重试消息和死信消息源码。 消费重试：并发消费和顺序消费对于消费失败的消息均会有消息重试机制。 1 并发消费重试

我的结构是这样的：日志文件 但我卡在Kafka到Logstash部分。 首先，Filebeat可以向Kafka生成消息，我可以使用以下方式检查它： 也可以由命令使用： 但是，当我尝试使用logstash来消费主题时，没有任何东西可以被检索到，Zoomaster一直在抛出： 2017-11-13 16:11:59205[myid:]-信息[NIOServerCxn.工厂：0.0.0.0/0.0.0.

问题是Spring Kafka侦听器只配置了主题名。 我似乎可以让Kafka产生100个消费者来处理来自“队列”（日志）的消息。怎么能做到呢？

我有一个场景，其中可执行文件是生产者，WCF服务是消费者。 WCF服务工作流程如下： 1） 服务调用可执行文件（producer），该可执行文件是另一个将消息生成RabbitMQ队列的进程。 2） 服务必须使用来自RabbitMQ队列的消息 3）将数据返回给客户端。 到目前为止，服务能够调用可执行文件并在队列中生成消息。 但服务从第2步开始失败，它将返回null而不是实际消息。有人能告诉我这里缺少

对于具有多个分区的主题- 1）单个SpringBoot实例是否使用多个线程来处理来自每个分区的每个消息（使用StreamListener注释的方法）？ 2）是否可以为每个分区配置多个线程，或者我必须手动从监听器线程切换到工作池？