Skip to content
This repository was archived by the owner on Oct 13, 2023. It is now read-only.

Commit cff6dd7

Browse files
Fix --consumer.config when no authentication method is set.
1 parent 8ecd423 commit cff6dd7

2 files changed

Lines changed: 7 additions & 1 deletion

File tree

README.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,10 @@ kcompose env
9595

9696
## Changelog
9797

98+
### 0.9.2
99+
100+
- \[Bug\] Fix --consumer.config when authentication method is set to NONE
101+
98102
### 0.9.1
99103

100104
- \[Bug\] Fix --command-config when authentication method is set to NONE

kcompose.sh

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,10 +48,12 @@ kafkaBinaries="$kafkaLocation/bin"
4848
programName=$(basename $0)
4949
commandConfig=""
5050
producerConfig=""
51+
consumerConfig=""
5152

5253
if [ ! -z "$credentialsFile" ]; then
5354
commandConfig="--command-config $credentialsFile"
5455
producerConfig="--producer.config $credentialsFile"
56+
consumerConfig="--consumer.config $credentialsFile"
5557
fi
5658

5759
# functions
@@ -414,7 +416,7 @@ Examples:
414416
topic=$2
415417
shift 2
416418
options=$*
417-
${kafkaBinaries}/kafka-console-consumer.sh --bootstrap-server $broker --topic $topic --consumer.config $credentialsFile $options
419+
${kafkaBinaries}/kafka-console-consumer.sh --bootstrap-server $broker --topic $topic $consumerConfig $options
418420
;;
419421
esac
420422
;;

0 commit comments

Comments
 (0)