小编aar*_*xer的帖子

如何杀死 Kafka 集群中的分布式工作人员?

我正在使用 Apache Kafka 并使用分布式工作线程。我可以按如下方式启动我的工人:

// Command to start the distributed worker.
"bin/connect-distributed.sh config/connect-distributed.properties"
Run Code Online (Sandbox Code Playgroud)

这是来自官方文档。之后我们可以创建连接器和任务。这很好用。

但是当我更改连接器或任务逻辑时,我应该jar向 kafka 的类路径添加新内容。之后我应该重新启动工作人员。

我不知道这应该如何正确,我认为我们应该停止并运行工人。

但是当我想停止工作时,我不知道如何正确地做到这一点。当然,我可以通过找到我的进程ps aux | grep worker,杀死它并杀死我也应该找到的其余服务器ps。但我认为这是一个奇怪的案例。杀死两个进程不是一个好主意,但我找不到任何信息如何以其他方式做到这一点。

如果您知道正确的方法,请帮助我:)

谢谢你的时间。

apache-kafka apache-kafka-connect

5
推荐指数
1
解决办法
3699
查看次数

PyQt QLineEdit 与 QValidator

我的项目中有一个 QLineEdit。\n我想在 lineEdit 上使用 QValidation。

\n\n
#Create lineEdit\nitemValue = QtWidgets.QLineEdit()\n#Create \xd0\xb2\xd0\xb0\xd0\xbb\xd0\xb8\xd0\xb4\xd0\xb0\xd1\x82\xd0\xbe\xd1\x80\nobjValidator = QtGui.QDoubleValidator(self)\n#setup range\nobjValidator.setRange(-10.0, 100.0, 5)\n#lineEdit with validation\nitemValue.setValidator(objValidator)\n
Run Code Online (Sandbox Code Playgroud)\n\n

但效果不佳。我可以输入我想要的内容,除了符号。\n并且范围不起作用!我可以输入 100500 或 -100500,但我希望用户只能输入范围内的数字。

\n\n

我应该如何使用范围?\n我需要帮助:)

\n\n

谢谢你们的帮助,伙计们!

\n

python qt qlineedit pyqt5

3
推荐指数
1
解决办法
8146
查看次数

Gradle 中所有存储库的相同凭据

请帮助我找到解决我的问题的最佳解决方案:

在专用 LAN 网络中,我有 Nexus 存储库,我需要使用一个用户来访问存储库。

最简单的解决方案是将用户和密码添加到gradle.properties文件中,并在每个build.gradle文件和每个存储库中写入相同的代码:

maven {
        credentials {
            username "$mavenUser"
            password "$mavenPassword"
        }
        url 'https://maven.yourcorp1.net/'
   }

maven {
        credentials {
            username "$mavenUser"
            password "$mavenPassword"
        }
        url 'https://maven.yourcorp2.net/'
   }
Run Code Online (Sandbox Code Playgroud)

其中gradle.properties所有存储库的 mavenUser 和 mavenPassword 都相同:

mavenUser=admin
mavenPassword=admin123
Run Code Online (Sandbox Code Playgroud)

一切都很好并且工作正常,但是有很多重复的代码。

也许您知道 - 如何在一个地方为所有 Maven 存储库设置相同的凭据?我不想为所有存储库复制相同的代码。

非常感谢你!

gradle build.gradle

2
推荐指数
1
解决办法
4149
查看次数