kafka-avro-console-consumer

#!/bin/bash
#
# Copyright 2018 Confluent Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

base_dir=$(dirname $0)/..

# Production jars
export CLASSPATH=$CLASSPATH:$base_dir/share/java/kafka-serde-tools/*

# Development jars. `mvn package` should collect all the required dependency jars here
for dir in $base_dir/package-kafka-serde-tools/target/kafka-serde-tools-package-*-development; do
  export CLASSPATH=$CLASSPATH:$dir/share/java/kafka-serde-tools/*
done

DEFAULT_AVRO_FORMATTER="--formatter io.confluent.kafka.formatter.AvroMessageFormatter"

DEFAULT_SCHEMA_REGISTRY_URL="--property schema.registry.url=http://localhost:8081"

for OPTION in "$@"
do 
  case $OPTION in
    --formatter)
      DEFAULT_AVRO_FORMATTER=""
      ;;
    --*)
      ;;
    *)
      PROPERTY=$OPTION
      case $PROPERTY in
        schema.registry.url*)
          DEFAULT_SCHEMA_REGISTRY_URL=""
        ;;
      esac
      ;;
    esac
done
exec $(dirname $0)/schema-registry-run-class kafka.tools.ConsoleConsumer $DEFAULT_AVRO_FORMATTER $DEFAULT_SCHEMA_REGISTRY_URL "$@"