我的kafka streams应用程序运行良好，在将processing\u guarange\u config设置为正好一次后，我的复制因子为3。
但是，我有一个dev环境，其中复制因子必须是1。根据文件，这只适用于开发。但是，即使在我将以下配置设置为1之后。启动时仍会出现transactionalidauthorizationexception。
Kafka\偏移量\主题\复制\因子Kafka\事务\状态\日志\复制\因子Kafka\事务\状态\日志\最小值\isr
我的kafka streams应用程序运行良好，在将processing\u guarange\u config设置为正好一次后，我的复制因子为3。
但是，我有一个dev环境，其中复制因子必须是1。根据文件，这只适用于开发。但是，即使在我将以下配置设置为1之后。启动时仍会出现transactionalidauthorizationexception。
Kafka\偏移量\主题\复制\因子Kafka\事务\状态\日志\复制\因子Kafka\事务\状态\日志\最小值\isr
1条答案
按热度按时间wz8daaqr1#
使用事务需要默认情况下的最小复制系数为3，即3个代理。您需要重新配置代理，以将这些默认设置减少到1。