《消息》专题

我看过与此相关的类似问题，但并没有找到正确的答案。我只想从 Kafka 主题中删除消息，而不是更改保留超时。我已经安装了kafka_2.11-0.8.2.1，并使用蝙蝠文件在Windows上运行它。我想知道我是否可以删除主题中发布的所有消息，而不删除整个主题。

我是Kafka的新手，当我试图发送信息到我得到的主题下面的错误。有人能帮我一下吗？ [2018-09-23 13:37:56,613]警告[Producer Clientid=Console-Producer]无法建立到节点-1的连接。代理可能不可用。（org.apache.kafka.clients.NetworkClient）

我有一个web应用程序，它通过WebLogic中的JMS与其他Java web应用程序通信。 我读到这样的答案：如何从PHP连接Jms？ 我安装了ActiveMQ并尝试使用它。但是在Weblogic中，我们需要“jms_factory”和“queue_name”。我想它使用t3协议。

使用SockJS java客户机，我试图连接到Spring SockJS服务器，但对于大约20KB的消息（没有标头），错误为1009。Javascript库工作正常。 还必须将Java SockJS客户端配置为接收更大的消息。 或者，服务器上的配置仍然错误。 如何在Java SockJS Spring客户机上增加缓冲区大小？

我正试图在Google play console上上传android应用程序的新版本，但当我选择该应用程序时，它会告诉我：“出现意外错误。请稍后再试。” 没有提供其他信息，3天前有效。我这边有什么问题吗，或者谷歌只是以某种方式破坏了他们的界面？ （我在unbuntu 18上使用google chrome）

采用具有窗口和消息循环的最简单的 Windows 程序，例如 Hello， World 程序。 假设就在我进入消息循环之前，我画进了窗口（在wm_paint处理之外顽皮地做了，但请耐心等待）。 如果在开始消息循环之前，我花了超过5秒的时间做这件事，或者我画了一些东西，然后花了5秒做其他事情，那么消息系统似乎“超时”。PeekMessage的MSDN文档称它变得“无响应”，并将其变成“幽灵”窗口。

最近，我一直在尝试教育自己如何使用Vigenere密码进行加密和解密。 我已成功加密该邮件,以下是我为实现加密所采取的步骤： 加密密钥：设置 消息：绝密 步骤1：键的数字表示为18、4、19（使用下表） E：P x k->C是加密函数 D：C x K->P为解密函数 明文：绝密 多谢了。

但是，问题是，我没有在日志部分得到任何消息，我没有找到如何自定义字段。 问题 这就是我的问题。是否可以将至少消息信息添加到事务日志（第一张图片），是否可以至少将自定义字段添加到日志部分（第二张图片），是否有方法使日志至少可点击？（也是第二张图片，我的意思是它只是纯文本，我必须去发现和使用这些信息，如ctrl c ctrl v）最后，为什么日志被标记为错误，如果它只是一个日志，并像日志一样使用？我试

我试图将日志文件索引到弹性搜索。所有日志条目都被索引到一个名为消息的字段中。@时间戳字段显示条目被索引的时间，而不是日志条目的时间戳。 我用grok processor创建了一个摄取管道来定义日志条目的模式。我尝试了几种模式，但都无法实现，尤其是因为我是新手。 日志样本 用grok吞食管道 我想要的就是能够从日志消息中提取时间戳，其他所有内容都可以被忽略、通配符或存储在一个变量中，比如消息。因此，

我在spring boot RESTfull项目中有一些特殊情况，而不是标准的自定义身份验证异常时的错误消息。我需要一个不同的消息取决于用户名或密码是错误的，或者如果用户名不存在，或者如果用户在数据库中被停用。目前我只能得到消息,我还没有找到任何解决方案,如何根据用户属性或特殊情况自定义消息。 我当前有如下自定义身份验证提供程序： 我有这样的定制用户详细信息服务： 在哪里可以处理来自的消息，并将其

我有一个应用程序，我正在使用谷歌播放服务广告Api显示添加，一切都很好，但我得到了一个消息： 找不到Google Play services资源。检查您的项目配置，以确保包括资源 请帮忙....

我的问题与Spring JMS（ActiveMQ）延迟传递消息非常相似，但与Spring boot自动配置程序更相关 我试图使用方法，但它抛出了一个 我试着从他那里找到合适的房产http://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html但找不到broker sche

我有一个Spring Boot应用程序，其中一个Kafka侦听器实现了BatchAcknowledgeingMessageListener 生成记录的代码如下所示： Kafka的配置看起来是这样的（这仍处于使用Testcontainers的集成测试阶段，因此制作人正在制作与消费者正在听的主题相同的内容）： 最后，消费者逻辑： 此示例的调试输出为： 正如你所看到的，这条消息正在用逗号分割，我收到的一

我们已经实现了延迟消息处理，有2个队列和x-死信-交换/x-消息-ttl，在queue1中的消息超时后，它将转到queue2。 现在是否有可能设置RabbitMQ，以便如果在处理来自queue2的消息时，我们将其拒绝为“死信”，那么它将自动转到queue3？我担心的是queue2中的消息已经标记为“已死”，有没有办法区分那些因为被拒绝而死的消息，并自动只将那些放在队列3中？

我正在尝试以avro格式对kafka消息进行解密我使用了以下代码：https://github.com/ivangfr/springboot-kafka-debezium-ksql/blob/master/kafka-research-consumer/src/main/java/com/mycompany/kafkaResearchconsumer/kafka/reviewsconsumerco