Kafka java生产者和消费者，启用了ACL并带有主题
我对kafka ACL配置有点困惑，在这里我们为生产者和消费者配置授权。有各种示例显示使用命令行生成/消费消息。我们是否需要任何额外的配置来使用JAVA api产生/消费消息到/从安全的kafka主题。
共有1个答案
@阿波罗：这个问题挺模糊的..如果您想学习ACL/SSL，需要一些时间。下面的链接可能会帮助您开始。https://github.com/symantec/kafka-security-0.9
-
本教程演示了如何发送和接收来自Spring Kafka的消息。 首先创建一个能够发送消息给Kafka主题的Spring Kafka Producer。 接下来，我们创建一个Spring Kafka Consumer，它可以收听发送给Kafka主题的消息。使用适当的键/值序列化器和解串器来配置它们。 最后用一个简单的Spring Boot应用程序演示应用程序。 下载并安装Apache Kafka 要
-
所谓的生产者消费者模型就是 某个模块（函数）负责生产数据，这些数据由另一个模块来负责处理 一般生产者消费者模型包含三个部分 生产者、缓冲区、消费者 为什么生产者消费者模型要含三个部分？直接生产和消费不行么？ 一个案例说明一切 生产者好比现实生活中的某个人 缓冲区好比现实生活中的邮箱 消费者好比现实生活中的邮递员 如果只有生产者和消费者, 那么相当于只有写信的人和邮递员，那么如果将来过去的邮递员离职
-
我有一个消费者作为生产者消费者模式的一部分： 简化： 如果我移除 通过将线程设置为睡眠，CPU使用率攀升到极高的水平（13%），而不是0%。 此外，如果我实例化该类的多个实例，则每个实例的CPU使用率都会以13%的增量攀升。 大约每分钟（可能每30秒）都会向BlockingCollection添加一个新的LogItem，并将适用的消息写入文件。 有没有可能线程以某种方式阻止了其他线程的运行，而系统
-
我想使用一个camel组件，它提供了使用和生成RESTful资源的能力。 对于这个例子，我想使用camel restlet组件。restlet组件一切正常，我已经使用REST DSL成功地实现了restlet consumer。然而，我有几个问题： 问题 1） 将restlet启用为异步是否安全？我读过restlet async可能会导致一些问题。这仍然正确吗？如何提高服务绩效？我应该改用码头吗？
-
生产者线程与消费者线程使用信号量同步 生产者线程与消费者线程使用信号量同步 源码/* * 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
-
我们有一个制作人 在开发过程中，我重新部署了producer应用程序，并做了一些更改。但在此之后，我的消费者没有收到任何消息。我尝试重新启动消费者，但没有成功。问题可能是什么和/或如何解决？ 消费者配置： 生产者配置： 编辑2： 5分钟后，消费者应用程序死亡，但以下情况除外：