当我使用confluent ksql创建一个流时，在将offeset重置为earlish并尝试查询流之后，我看到kafka服务器崩溃了。我用的是windows10，我试过ubuntu和debian作为wsl。
我尝试清除日志文件夹sudo rm-fr/tmp/confl*，并尝试使用confluent local start重新启动confluent平台，但kafka没有开始。
下面是我在合流本地日志kafka中看到的错误
INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-8 at epoch 0 (kafka.coordinator.transaction.TransactionStateManager)
[2020-06-26 11:27:26,208]**ERROR Error while renaming dir for _confluent-ksql-default_transient_1143297338875599674_1593157827320-Aggregate-Aggregate-Materialize-changelog-0 in log dir /tmp/confluent.HBnj6u7x/kafka/data (kafka.server.LogDirFailureChannel)
java.nio.file.AccessDeniedException: /tmp/confluent.HBnj6u7x/kafka/data/_confluent-ksql-default_transient_1143297338875599674_1593157827320-Aggregate-Aggregate-Materialize-changelog-0 -> /tmp/confluent.HBnj6u7x/kafka/data/_confluent-ksql-default_transient_1143297338875599674_1593157827320-Aggregate-Aggregate-Materialize-changelog-0.355fe6c61afa41609e74e252e3dbac92-delete**
[2020-06-26 11:27:26,287] WARN Stopping serving logs in dir /tmp/confluent.HBnj6u7x/kafka/data (kafka.log.LogManager)
[2020-06-26 11:27:26,292]**ERROR Shutdown broker because all log dirs in /tmp/confluent.HBnj6u7x/kafka/data have failed (kafka.log.LogManager)**
[2020-06-26 11:27:26,294] INFO [Transaction State Manager 0]: Completed loading transaction metadata from __transaction_state-44 for coordinator epoch 0 (kafka.coordinator.transaction.TransactionStateManager)
[2020-06-26 11:27:26,295] INFO [Transaction State Manager 0]: Loading transaction metadata from __transaction_state-27 at epoch 0 (kafka.coordinator.transaction.TransactionStateManager)
1条答案
按热度按时间wh6knrhe1#
这个
java.nio.file.AccessDeniedException错误消息告诉我ksql不能在wsl提供的文件系统中读/写文件。这可能与wsl没有在文件系统上提供正确的linux权限这一常见问题有关。一个可能的解决办法是描述在这个博客。无论如何，我鼓励您尝试使用ksqldb（confluent ksql的社区版本），它提供了基于docker的现成脚本，这样您就可以抽象出这些文件系统问题并直接跳到编码部分。
ksqldb快速启动