我在用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
暂无答案!
目前还没有任何答案,快来回答吧!