小编Vis*_*esh的帖子

控制台生产者中的领导者不可用Kafka

我正在尝试使用Kafka.所有配置都正确完成但当我尝试从控制台生成消息时,我不断收到以下错误

WARN Error while fetching metadata with correlation id 39 : 
     {4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
Run Code Online (Sandbox Code Playgroud)

kafka版本:2.11-0.9.0.0

有人可以帮忙,因为我无法在任何地方找到任何解决方案吗?

producer apache-kafka

147
推荐指数
12
解决办法
14万
查看次数

在Windows上运行Kafka时出错

我试图在Windows机器上运行Kafka,当我尝试启动动物园管理员时,我面临着这个奇怪的错误.

classpath是空的.请首先建立项目,例如运行'gradlew jarall'

任何帮助..?

Vishesh.

apache-kafka apache-zookeeper

10
推荐指数
7
解决办法
3万
查看次数

如何验证SSL适用于Kafka

我能够在我的kafka经纪人和客户端中设置SSL,我也能够看到当我们使用9093端口生成消息时,消息是消费者消费的SSL端口.

我尝试的是通过9093端口发送消息,并将消息发送给生产者的消费者.

我想是有办法真理,如果这是实际工作,我是说我怎么能证明9092是不是SSL和9093是SSL和安全吗?

先谢谢,Vishesh.

ssl apache-kafka

8
推荐指数
2
解决办法
6702
查看次数

Lerna 没有为每个包生成 package-lock.json

以下是问题的描述:-

预期行为是为包文件夹中的每个包生成一个 package-lock.json 文件。

当前行为 我当前的项目结构如下:-

packages/internal-package-1/package.json
packages/internal-package-2/package.json
packages/internal-package-3/package.json
lerna.json
package.json
package-lock.json
Run Code Online (Sandbox Code Playgroud)

现在如上图所示,只有一个 package-lock.json 文件是为 . 整个项目,它只包含顶部 package.json 文件中的依赖项。

我的期望是对于每个 package.json 文件都应该生成相应的 package-lock.json 但事实并非如此。此外,顶层 package-lock.json 文件仅包含顶层 package.json 中的依赖项,而不包含在每个 package.json 文件中声明的所有依赖项。

现在,如果我们尝试在不同的项目中使用例如 internal-package-1 ,因为此包没有锁定文件,则会下载最新版本的依赖项,这不是预期的行为。

可能的解决方案 可能的解决方案或期望是为每个包生成一个锁定文件。

lerna.json

{
  "packages": [
    "packages/*",
    "packages/Foundation/src/SampleNestedModule"    
  ],
  "version": "0.0.0"
}
Run Code Online (Sandbox Code Playgroud)

这个问题正在影响我们,因为锁定文件不是为每个包生成的,如果我尝试在不同的项目中使用 internal-package-1,那么锁定的依赖项不会被下载,但它们的最新版本会被下载。

我们正在提升依赖项,因此我们修改了 npm install 脚本,如下所示:- "install": "lerna bootstrap --hoist",这正确提升了依赖项,但不会为单个包生成锁定文件。

可执行版本

lerna --version 3.17.0
npm --version   6.10.1
yarn --version  Not using yarn
node --version  10.16.0
| OS | Version |
MACOS
| NAME …
Run Code Online (Sandbox Code Playgroud)

lerna package-lock.json

6
推荐指数
1
解决办法
2194
查看次数