使用属性文件的kafka主题configuration
我想configuration一些主题和独特的保留设置Kafka。 所以当我启动Kafka时,它将使用这些设置加载server.properties文件。
我发现的唯一方法是启动Kafka,然后使用kafka-topics.sh
脚本启动和configuration主题。
例:
bin/kafka-topics.sh --zookeeper zk.yoursite.com --alter --topic as-access --config retention.ms=86400000
我在Docker上使用Kafka,所以我不需要将入口点设置为启动Kafka的实际脚本,而是需要创build自己的脚本来启动Kafka并运行一些shell命令来configuration这些主题。 另外,如果我需要自己创build这些主题,则需要开始创build一些关于已经存在的主题的逻辑。 我不想走那条路
- 使JMX与spotify / kafka Docker镜像一起工作
- 卡夫卡与docker问题
- 创build主题,但在Kubernetes上使用Python获取Kafka FailedPayloadsError
- 未能在MacOS上Docker化Kafka
- Docker与Zookeeper,Kafka,Redis和Java Spring Boot组合
- Docker上的Apache Kafka – 在数百个游泳池后停止
- 是否有可能使用卡夫卡与docker组成一个单一的主机,而不暴露动物园pipe理员和卡夫卡端口到公共互联网?
- 卡夫卡生产者configuration和docker工人
- 将消息发布到docker中运行的Kafka