当使用处理器API的Kafka流从源读取并写入主题列表时,我想测试一个或两个主题是不可访问的(失败测试:试图通过添加集群中不存在的1/2主题来模拟它)。("sink1 or sink2 or sink3"));
我的理解是,kafkaStreams应该为不存在的主题提供错误,并继续将记录转发到topic1和存在的2。"TOPIC\_X" due to org.apache.kafka.common.errors.TimeoutException: Top
我有一个包含ID/Topic/Definition列的数据库。当使用可能有数百个参数的select查询时,我希望fetchall调用也能返回任何不存在的行的主题和默认文本(即“未找到”)。对于SQLite中不存在的行,有没有办法用默认文本获取查询(主题)的返回结果?表结构(命名为“字典”)1|wd1|def1示例查询
SELECT Topic,Definition FROM dictionaryWHERE