当我使用confluent创建一个流时,在重新设置该流后,并试图查询该流,我将看到Kafka服务器崩溃。我正在使用windows 10,我已经尝试了Ubuntu和Debian作为WSL。
我尝试过清除日志文件夹sudo rm -fr /tmp/confl*,并尝试使用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)
发布于 2020-06-26 15:14:05
java.nio.file.AccessDeniedException
错误消息告诉我,关于KSQL能够在WSL提供的文件系统中读取/写入文件,有些东西是错的。这可能与WSL没有为文件系统提供适当的Linux权限这一常见问题有关。一个可能的解决方法是描述在这个博客上。
无论如何,我鼓励您尝试使用ksqlDB ( Confluent的社区版本),它提供了基于Docker的现成的可用脚本,这样您就可以抽象出这些文件系统问题,直接跳转到编码部分。
https://stackoverflow.com/questions/62592125
复制相似问题