SpringKafka不能正确关闭
我错过了什么关于正确关闭生产者和消费者的事情吗？
共有1个答案
你不说你使用的是哪个版本。
这在2.1.0、2.0.2和1.3.2中得到了修正。
您不需要从destroy()方法中停止()容器；上下文在关闭时将停止使用者。
-
我有一个springboot应用程序，它侦听Kafka流并将记录发送到某个服务以进行进一步处理。服务有时可能会失败。注释中提到了异常情况。到目前为止，我自己模拟了服务成功和异常场景。 侦听器代码： 用户工厂配置如下： 由于REST服务正在抛出RestClientException，它应该进入上面提到的if块。关于FixedBackOff，我不希望SeekToCurrentErrorHandler执
-
我有一些代码，其中多个方法使用键盘，并在主方法中连续调用。我正在做的练习特别要求使用4种不同的方法，所以我不能把它们放在一起。最初，我用键盘。在每个方法的末尾关闭（），但当第二个方法运行时，无论调用顺序如何，这都会导致NoTouchElementException。通过卸下键盘。close（），代码现在可以工作了，但是我现在收到了资源泄漏的警告，因为键盘没有关闭。有人能告诉我一种关闭输入而不出错的
-
问题内容： 我有一个似乎无法满足的简单要求：我有一个产品页面。产品具有供应商，供应商输入是带有自动完成功能的文本字段。如果用户输入数据库中不存在的供应商，则需要添加它。要添加它，我在.load（）页面上有一个DIV并调用了我的/ Vendor / Create控制器方法。该方法的视图使用： 这应该通过ajax发布我的表单，完成后调用Javascript。我遇到的问题是，提交后，我的整个页面都会刷新
-
问题内容： 我想在Java中实现SSL代理。我基本上打开了两个套接字，并运行了两个线程，这些线程将写入他们从中读取的内容，反之亦然。每个线程如下所示： 每个线程只会关闭输入套接字，因此最终两个套接字都会关闭。 但是，如果我想使用an 怎么办？似乎那里不支持这些方法。这是我得到的例外。 我想出的是： 每当套接字结束时，我都必须捕获并忽略套接字末尾异常。 我的问题是： 如果不受支持，我怎么会从那里得到
-
我在同一个jvm中运行Netty客户端和服务器并试图停止服务器时遇到问题。以下是我的代码来举例说明： 我已经用Netty 3.4.0测试过了。最终和3.4.4。最后，我不知道我做错了什么。 为什么在服务器关闭后，客户端仍然可以向服务器发送数据？
-
我正在处理一个需要使用jFileChooser Swing窗口的项目。当单击“取消”或“打开”时，窗口不会关闭。在查看了StackOverflow上的许多文章以及JFileChooser教程和文档之后，我不知道是什么导致了这个重复的问题。 我正在与NetBeans一起使用它的swing编辑器。我也在Eclipse中尝试了该程序作为测试，并收到了相同的结果。