Commit b2825ad 1 parent abad97a commit b2825ad Copy full SHA for b2825ad
File tree 1 file changed +2
-0
lines changed
psc/src/main/java/com/pinterest/psc/consumer/kafka
1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -1145,6 +1145,7 @@ protected void initializeKafkaConsumer() {
1145
1145
pscConfigurationInternal .getConfiguration ()
1146
1146
.getString (PSC_CONSUMER_KAFKA_CONSUMER_CLASS );
1147
1147
try {
1148
+ logger .info ("Initializing Kafka consumer with class: " + kafkaConsumerClassName );
1148
1149
if (kafkaConsumerClassName != null ) {
1149
1150
Class <?>
1150
1151
kafkaConsumerClass =
@@ -1153,6 +1154,7 @@ protected void initializeKafkaConsumer() {
1153
1154
(Consumer ) kafkaConsumerClass .getDeclaredConstructor (Properties .class )
1154
1155
.newInstance (properties );
1155
1156
} else {
1157
+ logger .info ("No custom Kafka consumer class specified, defaulting to native KafkaConsumer class" );
1156
1158
kafkaConsumer = new KafkaConsumer <>(properties );
1157
1159
}
1158
1160
} catch (ClassNotFoundException | InstantiationException | IllegalAccessException |
You can’t perform that action at this time.
0 commit comments