如何在docker中配置kafka避免policyviolationexception删除记录

yftpprvb  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(281)

我在用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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题