141.kafka连接测试

发表于 linux 分类，标签:
29 01月 2024
0 
#!/bin/bash

KAFKA_BROKER="hadoop001:9092"
TOPIC="test-topic"

function test_kafka_connection {
    echo "Testing Kafka connection..."

    # 创建 Kafka 生产者
    /home/lei/kafka_2.13-3.3.1/bin/kafka-producer-perf-test.sh --topic $TOPIC --num-records 1 --record-size 1 --throughput 1 --producer-props bootstrap.servers=$KAFKA_BROKER

    # 创建 Kafka 消费者
    /home/lei/kafka_2.13-3.3.1/bin/kafka-consumer-perf-test.sh --bootstrap-server $KAFKA_BROKER --topic $TOPIC --fetch-size 1 --messages 1

    # 检查命令执行结果
    if [ $? -eq 0 ]; then
        echo "Kafka connection successful!"
        return 0
    else
        echo "Kafka connection failed."
        return 1
    fi
}

# 测试 Kafka 连接
test_kafka_connection


0 篇评论

发表我的评论