Apache Kafka生产者和消费者的Spring Slueth实现
我没有使用Spring Kafka模块来生成和使用消息。相反，我在生产者和消费者实现中使用Apache客户端库。由于我没有使用Spring Kafka，因此Spring Slueth自动配置不适用于生成跟踪。我已经提到https://docs.spring.io/spring-cloud-sleuth/docs/current-SNAPSHOT/reference/html/integrations.html我没有找到任何关于如何将Spring Slueth应用于使用第三方库的代码的文档？
共有1个答案
如果您没有使用Spring，那么不要将其添加到非Spring代码中。
Sleuth中的跟踪是使用Brave Kafka Interceptor实现的
-
本教程演示了如何发送和接收来自Spring Kafka的消息。 首先创建一个能够发送消息给Kafka主题的Spring Kafka Producer。 接下来，我们创建一个Spring Kafka Consumer，它可以收听发送给Kafka主题的消息。使用适当的键/值序列化器和解串器来配置它们。 最后用一个简单的Spring Boot应用程序演示应用程序。 下载并安装Apache Kafka 要
-
我想使用一个camel组件，它提供了使用和生成RESTful资源的能力。 对于这个例子，我想使用camel restlet组件。restlet组件一切正常，我已经使用REST DSL成功地实现了restlet consumer。然而，我有几个问题： 问题 1） 将restlet启用为异步是否安全？我读过restlet async可能会导致一些问题。这仍然正确吗？如何提高服务绩效？我应该改用码头吗？
-
在这种情况下，我是否需要求助于Kafka事务API来在消费者轮询循环中创建事务生产者，在该循环中，我在事务中执行：（1）处理消耗的记录和（2）在关闭事务之前提交它们的偏移量。在这种情况下，普通的commitsync/commitasync是否有效？
-
生产者线程与消费者线程使用信号量同步 生产者线程与消费者线程使用信号量同步 源码/* * Copyright (c) 2006-2018, RT-Thread Development Team * * SPDX-License-Identifier: Apache-2.0 * * Change Logs: * Date Author Notes * 2018-08-24 yangjie the f
-
所谓的生产者消费者模型就是 某个模块（函数）负责生产数据，这些数据由另一个模块来负责处理 一般生产者消费者模型包含三个部分 生产者、缓冲区、消费者 为什么生产者消费者模型要含三个部分？直接生产和消费不行么？ 一个案例说明一切 生产者好比现实生活中的某个人 缓冲区好比现实生活中的邮箱 消费者好比现实生活中的邮递员 如果只有生产者和消费者, 那么相当于只有写信的人和邮递员，那么如果将来过去的邮递员离职
-
我有一个消费者作为生产者消费者模式的一部分： 简化： 如果我移除 通过将线程设置为睡眠，CPU使用率攀升到极高的水平（13%），而不是0%。 此外，如果我实例化该类的多个实例，则每个实例的CPU使用率都会以13%的增量攀升。 大约每分钟（可能每30秒）都会向BlockingCollection添加一个新的LogItem，并将适用的消息写入文件。 有没有可能线程以某种方式阻止了其他线程的运行，而系统