diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-19 02:57:58 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-19 02:57:58 +0000 |
| commit | be1c7e50e1e8809ea56f2c9d472eccd8ffd73a97 (patch) | |
| tree | 9754ff1ca740f6346cf8483ec915d4054bc5da2d /fluent-bit/lib/librdkafka-2.1.0/tests/lz4_manual_test.sh | |
| parent | Initial commit. (diff) | |
| download | netdata-be1c7e50e1e8809ea56f2c9d472eccd8ffd73a97.tar.xz netdata-be1c7e50e1e8809ea56f2c9d472eccd8ffd73a97.zip | |
Adding upstream version 1.44.3.upstream/1.44.3upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'fluent-bit/lib/librdkafka-2.1.0/tests/lz4_manual_test.sh')
| -rwxr-xr-x | fluent-bit/lib/librdkafka-2.1.0/tests/lz4_manual_test.sh | 59 |
1 files changed, 59 insertions, 0 deletions
diff --git a/fluent-bit/lib/librdkafka-2.1.0/tests/lz4_manual_test.sh b/fluent-bit/lib/librdkafka-2.1.0/tests/lz4_manual_test.sh new file mode 100755 index 00000000..7c604df7 --- /dev/null +++ b/fluent-bit/lib/librdkafka-2.1.0/tests/lz4_manual_test.sh @@ -0,0 +1,59 @@ +#!/bin/bash +# + +# +# Manual test (verification) of LZ4 +# See README for details +# + +set -e +# Debug what commands are being executed: +#set -x + +TOPIC=lz4 + +if [[ $TEST_KAFKA_VERSION == "trunk" ]]; then + RDK_ARGS="$RDK_ARGS -X api.version.request=true" +else + if [[ $TEST_KAFKA_VERSION == 0.8.* ]]; then + BROKERS=$(echo $BROKERS | sed -e 's/PLAINTEXT:\/\///g') + fi + RDK_ARGS="$RDK_ARGS -X broker.version.fallback=$TEST_KAFKA_VERSION" +fi + +# Create topic +${KAFKA_PATH}/bin/kafka-topics.sh --zookeeper $ZK_ADDRESS --create \ + --topic $TOPIC --partitions 1 --replication-factor 1 + +# Produce messages with rdkafka +echo "### Producing with librdkafka: ids 1000-1010" +seq 1000 1010 | ../examples/rdkafka_example -P -b $BROKERS -t $TOPIC \ + -z lz4 $RDK_ARGS + +# Produce with Kafka +echo "### Producing with Kafka: ids 2000-2010" +seq 2000 2010 | ${KAFKA_PATH}/bin/kafka-console-producer.sh \ + --broker-list $BROKERS --compression-codec lz4 \ + --topic $TOPIC + +# Consume with rdkafka +echo "### Consuming with librdkafka: expect 1000-1010 and 2000-2010" +../examples/rdkafka_example -C -b $BROKERS -t $TOPIC -p 0 -o beginning -e -q -A \ + $RDK_ARGS + +# Consume with Kafka +echo "### Consuming with Kafka: expect 1000-1010 and 2000-2010" +if [[ $TEST_KAFKA_VERSION == "trunk" ]]; then + ${KAFKA_PATH}/bin/kafka-console-consumer.sh -new-consumer \ + --bootstrap-server $BROKERS --from-beginning --topic $TOPIC \ + --timeout-ms 1000 +else + ${KAFKA_PATH}/bin/kafka-console-consumer.sh \ + --zookeeper $ZK_ADDRESS --from-beginning --topic $TOPIC \ + --max-messages 22 +fi + + +echo "" +echo "### $TEST_KAFKA_VERSION: Did you see messages 1000-1010 and 2000-2010 from both consumers?" + |