当前位置: 首页 > 知识库问答 >
问题:

通过用于Apache Ignite的Kafka Connect进行DC复制

佟和平
2023-03-14

我们正在尝试在两个Ignite数据集群之间实现数据复制。

为此,我们使用Kafka Connect。

我们遵循了本文件中提到的内容-

在我们使用一个缓存和PUT操作之前,一切都正常。

但是,当我将其用于删除操作时,在连接器的使用者线程中,我可以看到CacheEvent记录,但数据没有从接收器群集节点中删除。

有人能帮忙处理这个案子吗?

共有1个答案

鲁鸿朗
2023-03-14

这可能是Ignite Kafka集成的问题。尝试收集所有相关详细信息并通过用户列表向Ignite社区报告。

同时,如果问题没有解决,您可以考虑其他复制选项:

  1. 通过认证的GridGain Kafka Connect集成进行复制。
  2. GridGain的数据中心复制功能
 类似资料:
  • 赋值运算符(=)可以将一个对象赋给另一个相同类型的对象。这种赋值默认通过成员复制(memberwisecopy)进行,对象的每个成虽一一复制给另一对象的同一成员(如图6.L1)(注意:如果类的数据成员包含动态分配存储体,则通过默认的成员复制赋值可能导致严重问题,第8章“运算符重载”中将介绍这些问题及其处理方法)。 对象可以作为函数参数传递并从函数返回。这种传递和返回默认按值调用进行,即传递和返回对

  • 利用通配符进行复杂的数据操作。 LIKE 与 REGEXP 操作符 当需要搜索产品文本中包含某个特定关键字的所有产品,使用通配符来创建比较特定的数据搜索模式。 通配符(wildcard) 用来匹配值的一部分特殊字符。 搜索模式(search pattern) 由字母值,通配符两租组合构成的搜索条件。 通配符是SQL的WHERE子句中的特殊含义字符,子句中使用通配符必须使用LIKE操作符。 百分号%

  • 我有两个桶: “source-bucket”(在AWS帐户88888888中)。 “目的地-桶”(在AWS帐户99999999中) 两个桶都启用了版本控制,并且位于同一区域(eu-west-1)。 在源桶中,我创建了一个具有以下设置的复制规则: 我选择了自动角色创建,它使用以下策略创建了一个角色: 根据这里找到的文档https://docs.aws.amazon.com/amazons3/late

  • 我很快就开始使用libGDX,我正在制作一个游戏,其中水滴从屏幕顶部落下,用户应该在触摸屏幕底部之前点击它们。我在知道用户是否确实点击了飞沫来执行某些操作时遇到了问题。 这是我的渲染方法: 窃听密码好像不管用。 如果有人能解释一下他们的答案,我将不胜感激。谢谢。

  • 问题内容: 我有一个MySql表,我想查询其中 成对 的列在特定集中的行。例如,假设我的表格如下所示: 现在,我希望提取其中 (f1,f2) 对为(’a’,30)或(’b’,20)的行,即行2,3,4。我也希望使用“ IN”样式的过滤器来完成此操作,因为我可能有很多对要提取。如果我尝试类似的方法: 我得到IN子句中为f1和f2指定的值的笛卡尔积,即具有f1 =’a’或’b’的所有可能组合的行,以及

  • 问题内容: 我在JTextfield上输入了一个名称,但是我的表没有过滤任何东西! 我的代码: 问题答案: 您正在呼叫的 构造。它应该如何从filterTF中读取 文本 。我认为您应该从分配给的Action Event Listener调用它,提交(单击)文本时将调用它,如下所示: 如果要使用“根据用户键类型进行过滤”事件,请将键侦听器添加到您要输入过滤字符串的文本字段中。 但是,正如下面的注释所