我知道如何删除Kafka连接器,如此处所述 Kafka Connect - 如何删除连接器
但我不确定它是否也删除/擦除特定的连接器相关的配置,偏移量和状态从*。sorage.topic该工作者?
例如:假设我删除了一个连接器名为“connector-abc-1.0.0”的连接器,Kafka connect worker以下面的配置启动。
offset.storage.topic=<topic.name>.internal.offsets
config.storage.topic=<topic.name>.internal.configs
status.storage.topic=<topic.name>.internal.status
因为Kafka是append only,所以那些Connect主题中的消息被删除的唯一方法是使用连接器名称作为消息键,并且< code>null作为值来发布它。
您可以使用控制台使用者检查这些主题,以查看其中包含哪些数据,包括--propertyprint。key=true
,并在删除连接器时保持使用者运行。
您可以在 /
connectors/{name}/config
放置一个新配置,但使用的任何特定偏移量都取决于实际连接器类型(接收器/源);例如,有接收器连接器使用的内部 Kafka __consumer_offsets
主题,以及源连接器可以选择使用的 offset.storage.topic
。
相同的名称在同一个工人,但不同的配置(不同的offset.start或connector.class)?
我不确定改变connector.class
是否是一个好主意,因为它会完全改变连接器的行为。offset.start
不是我知道的属性,所以您需要查看特定连接器类的留档才能知道它的作用。
删除连接器时,偏移量将保留在偏移主题中。如果您重新创建同名连接器,它将重新使用上一次执行中的偏移量(即使连接器在两者之间被删除)。
我参考了以下链接来了解Kafka的HDFS连接https://docs.confluent.io/2.0.0/Connect/connect-hdfs/docs/index.html 我能够通过配置单元集成将数据从Kafka导出到HDFS。 现在我正尝试在Java程序的帮助下将avro记录写入Kafka 当我把Avro记录写到Kafka主题时,我在Connect中出现以下错误
使用jsPlumb,我成功地进行了以下设置: 有多个节点与特殊类型流程图中的节点类似。 先举个小例子:http://fiddle.darkspot.ch/ivr/flowchart/ivrplumb.html (经过一个小时的尝试,不幸的是我没有让它在JSFIDLE上运行——所以我自己主持了它) 我想要实现的是:如果用户将新连接从一个出口拖到另一个节点,那么应该按照预期建立连接。但是应该删除此出口
我正在使用jsPlumb创建一个包含两列的匹配小部件。 jsPlumb实例创建为: 我创建了源和目标,如下所示: 连接过程正常工作。但是在建立一个连接后的问题如果我删除连接,连接endpoint仍然可见。 我尝试添加配置“\u deleteondetch”,还尝试删除connectiondeach上的endpoint。在这两种情况下,endpoint都被删除,但在我尝试连接相同的元素时,它会出错。
我正在处理一个管道问题。当我试图以编程方式删除所有元素连接时,我得到了未捕获的TypeError:无法读取未定义的属性“left” 我有几个节点(html元素),每个都有1个输入endpoint(接受的终端)和n个输出endpoint。每个节点后面还有一个javascript对象。我的软件中有一个“选定”状态。用户可以选择多个节点,并将对象推送到一个称为选择的数组。我有一个删除键的键侦听器。当按下
我指的是这个例子。 它使用jsPlumb版本2.4.3,我想删除所有连接,但它不起作用,要删除所有连接,我正在使用这段代码。 要删除单个连接,我使用下面的代码,但它显示。分离不是一个函数。 jsplumb是否存在任何版本问题。 任何帮助将高度赞赏。谢啦
我正在使用jsplumb,但是我无法删除两个只有一个div的id的div之间的连接。