我正在建立一个 Dockerized Confluent 控制中心,它指向我们的 Confluent Cloud Kafka,我在这里和这里遇到了这个常见问题:
[2019-07-31 20:40:28,023] ERROR [main] attempt=failed to create topic=TopicInfo{name=_confluent-metrics, partitions=12, replication=3} (io.confluent.controlcenter.KafkaHelper)
org.apache.kafka.common.errors.PolicyViolationException: Config property 'max.message.bytes' with value '10485760' exceeded max limit of 8388608.
根据这些参考资料,解决方案是设置一个属性:
confluent.metrics.topic.max.message.bytes=8388608
不幸的是,经过几次变化后,我找不到合适的环境来让魔法发生。这是我在 docker-compose.yml 中尝试过的所有变体:
CONTROL_CENTER_OPTS: "-Dconfluent.metrics.topic.max.message.bytes=8388608"
CONFLUENT_METRICS_TOPIC_MAX_MESSAGE_BYTES: 8388608
CONFLUENT_METRICS_REPORTER_TOPIC_MAX_MESSAGE_BYTES: 8388608
CONFLUENT_METRICS_REPORTER_MAX_REQUEST_SIZE: 8388608
CONFLUENT_METRICS_REPORTER_MAX_MESSAGE_BYTES: 8388608
MAX_MESSAGE_BYTES: 8388608
有没有人成功地将 C3 容器连接到 Confluent Cloud?或者,更具体地说,通过了这个障碍?
最终目标是拥有一个 UI,用于查看在本地运行但连接到 Confluent Cloud 的 dockerized KSqlDB/cli。