我为3个节点的Kafka集群设置了ACL,可以通过生产者控制台和消费者控制台发送和接收主题。现在我想使用ACL配置Kafkaconnect。我尝试使用SASL_PLAINTEXT组合,在connect.log文件中显示以下错误。它没有从源表同步到主题,请帮助我缺少任何配置的地方。to flush, timed out while waiting for producer to flush outs
我们有一个基于Kafka的系统,并且有一个庞大的开发团队在这个系统上工作。我们还在开发和测试阶段,还没有投入生产。对于大多数本地开发人员测试,我们不需要使用Kafka消息,但我们需要与QA环境中的数据库和其他应用程序进行交互,因此开发人员在运行其应用程序(这些是Java Spring Boot应用程序)时将使用QA问题是,当开发人员使用QA配置文件在本地运行应用程序时,本地应用程序会消耗来自QA环境的消息并中断测试。我们还有一个更大的
每当我尝试连接到kafka的生产者/消费者,我得到“未授权的主题test2” 如果我关闭了授权,我成功地通过了身份验证,所以身份验证可以工作,只有授权不能。在kafka.security.auth.SimpleAclAuthorizer不起作用的情况下进行ACL授权。] DEBUG No acl found for resource Topic:LITERAL:test2, authorized = false (kafka