时间戳

首页 > 解决方案 > 如何在 Docker 中配置 Kafka 以避免删除记录的 PolicyViolationException

docker - 如何在 Docker 中配置 Kafka 以避免删除记录的 PolicyViolationException

问题描述

我使用https://github.com/bitnami/bitnami-docker-kafka作为开发环境。但是，当我使用

kafka-delete-records --bootstrap-server localhost:9092 --offset-json-file tmp16523977715454317626.json

我收到此错误：

Executing records delete operation
Records delete operation completed:
partition: market.ledger-2      error: org.apache.kafka.common.errors.PolicyViolationException: Request parameters do not satisfy the configured policy.

这是我目前docker-compose.yml对 kafka 的条目。我已经KAFKA_CFG_DELETE_TOPIC_ENABLE按照建议在几页上进行了设置，但仍然出现此错误。我认为这很明显，并希望得到一些帮助。

  kafka:
    image: 'bitnami/kafka:2.3.1'
    ports:
      - '9092:9092'
    environment:
      KAFKA_CFG_ZOOKEEPER_CONNECT: 'zookeeper:2181'
      ALLOW_PLAINTEXT_LISTENER: 'yes'
      KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: 'INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT'
      KAFKA_CFG_LISTENERS: 'INTERNAL://:29092,EXTERNAL://:9092'
      KAFKA_CFG_ADVERTISED_LISTENERS: 'INTERNAL://kafka:29092,EXTERNAL://localhost:9092'
      KAFKA_CFG_INTER_BROKER_LISTENER_NAME: INTERNAL
      KAFKA_CFG_DELETE_TOPIC_ENABLE: 'true'
    depends_on:
      - zookeeper

标签： dockerapache-kafka

解决方案

推荐阅读