1. 内外网同时访问
-
配置
只添加 advertised.listeners 这一行即可。
listeners=SASL_PLAINTEXT://172.xxx.28.149:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
advertised.listeners=SASL_PLAINTEXT://47.xxx.xxx.140:9092
-
应用场景
如阿里云，绑定弹性IP后给外网使用。
2. kafka内存设置
- kafka-eagle上可以看到如下信息
image.png
- 增加内存只需要配置kafka服务的jvm虚拟机即可
修改配置文件/opt/kafka/bin/kafka-server-start.sh
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-server -Xms10G -Xmx10G -XX:PermSize=128m -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:ParallelGCThreads=8 -XX:ConcGCThreads=5 -XX:InitiatingHeapOccupancyPercent=70"
export JMX_PORT="9999"
fi
- 重启kafka
（略） -
查看结果
image.png
3. kafka的存储位置
默认位置
默认存储在tmp下kafka-logs目录，实际是kafka的存储目录。
tmp在根目录，数据肯定不能放在这个位置。修改
/opt/kafka/config/server.properties
############################# Log Basics #############################
# A comma separated list of directories under which to store log files
log.dirs=/data/kafka-logs
4. Daemo 模式启动
-
nohup启动
（不推荐）
nohup /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties 1>/dev/null 2>&1 &
-
以demean模式启动
（推荐）
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
