| commit | 0edf0b1df77da7abbd81fe99bbba6c5941ca2354 | [log] [tgz] |
|---|---|---|
| author | adibrastegarnia <adib.rastegarnia@gmail.com> | Sun Nov 11 21:25:15 2018 -0500 |
| committer | Ray Milkey <ray@opennetworking.org> | Tue Nov 13 22:09:58 2018 +0000 |
| tree | 6ab041fd3a815dcc08f63e47b54e54ce84b93f43 | |
| parent | d175194107bed35d91155349ffd5efd898390db6 [diff] |
[FIX]-a bug in kafka-integration app has been fixed. Change-Id: Ib6f21acac161da9bbc3cd9b9f42540def64c641b
diff --git a/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/kafka/KafkaConfigManager.java b/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/kafka/KafkaConfigManager.java index 4b90b8e..078b10c 100644 --- a/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/kafka/KafkaConfigManager.java +++ b/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/kafka/KafkaConfigManager.java
@@ -71,7 +71,7 @@ protected String keySerializer = KEY_SERIALIZER_DEFAULT; /** Serializer class for value that implements the Serializer interface. */ - protected String valueSerializer = VALUE_SERIALIZER; + protected String valueSerializer = VALUE_SERIALIZER_DEFAULT; @Activate protected void activate(ComponentContext context) {