创建SCRAM凭据直接在zookeeper/Kafka
通常kafka-configs.sh用于创建SCRAM凭据，以便使用此命令进行身份验证
> bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=alice-secret],SCRAM-SHA-512=[password=alice-secret]' --entity-type users --entity-name alice
有没有其他方法可以创建这些凭证，直接在zookeeper上或者通过Java？
共有1个答案
kafka管理客户端没有提供创建SCRAM凭证的方法，我所做的是将Kafka二进制文件下载到我的节点上，并使用java中的进程运行上述命令。
Process process = new ProcessBuilder(new String[] {"bash", "-c", cmdline})
.redirectErrorStream(true)
.directory(new File(directory))
.start();
-
为了和Azure IoT设备通信，在创建设备之后会获得设备连接字符串，我们需要用这个字符串创建一个连接凭据。 请求方式： "|4|2|1|connectionString|" 参数 connectionString 设备连接字符串 返回值： "|4|2|1|1|\r" 创建成功 "|4|2|1|2|reason|\r" 创建失败 参数 reason 创建失败的原因 Arduino样例： softS
-
当销毁一个设备连接凭据后，可以通过这条指令再次创建设备连接凭据。 请求方式： "|4|2|5|\r" 返回值： "|4|2|1|1|\r" 创建成功 "|4|2|1|2|reason|\r" 创建失败 参数 reason 创建失败的原因 Arduino样例： softSerial.print("|4|2|5|\r");
-
因此，我想知道做这件事的步骤。 我的理想是由kafka Connect创建与表相对应的主题，然后再由我声明（使用KSQL）创建视图。 虽然我在这里描述的一开始听起来是可行的，但我对数据有一个问题主题中数据的结构（模式）。问题似乎是，我可能必须做一个额外的步骤，但不知道它是否可以避免或实际上是必要的。
-
当用户在他们的项目中，并且他们转到“API和服务”>Credentials时，用户会收到这个错误：您没有权限查看API密钥、OAuth客户机和服务帐户密钥。 角色/权限：-App Engine Admin-Cloud Functions Developer-Cloud Datastore Owner-Service Account Admin-Source Repository Administr
-
我正在使用现有的Java代码，其中在部署的系统上有一个现有的JDBC连接池机制，并且有一个已经存在的获取JDBC连接的设置。我想利用这一点来创建MyBatis SqlSession对象，而不创建配置、数据源和其他东西 我的代码已经创建了对象，并为其提供了所需的资源。我想利用这一点，获得对象，并从此使用MyBatis。 我不希望MyBatis管理连接池，确定使用哪个数据源等等，这可能吗？
-
问题内容： 我有一个数据块，当前为n元组列表，但格式相当灵活，我想附加到Postgres表中-在这种情况下，每个n元组都对应于数据库中的一行。 到目前为止，我一直在做的工作是将所有内容都写入CSV文件，然后使用postgres的COPY将所有内容批量加载到数据库中。这可行，但不是最佳选择，我希望能够直接从python进行所有操作。python中是否有一种方法可以在Postgres中复制COPY类型