2 * ============LICENSE_START=======================================================
\r
4 * ================================================================================
\r
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
\r
6 * ================================================================================
\r
7 * Licensed under the Apache License, Version 2.0 (the "License");
\r
8 * you may not use this file except in compliance with the License.
\r
9 * You may obtain a copy of the License at
\r
11 * http://www.apache.org/licenses/LICENSE-2.0
\r
13 * Unless required by applicable law or agreed to in writing, software
\r
14 * distributed under the License is distributed on an "AS IS" BASIS,
\r
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
16 * See the License for the specific language governing permissions and
\r
17 * limitations under the License.
\r
18 * ============LICENSE_END=========================================================
\r
21 package com.att.nsa.cambria.backends.kafka;
\r
23 import static org.junit.Assert.*;
\r
25 import java.io.IOException;
\r
27 import org.junit.After;
\r
28 import org.junit.Before;
\r
29 import org.junit.Test;
\r
31 import kafka.javaapi.consumer.ConsumerConnector;
\r
33 public class KafkaConsumerTest {
\r
36 public void setUp() throws Exception {
\r
40 public void tearDown() throws Exception {
\r
45 public void testGetName() {
\r
47 String topic = "testTopic";
\r
48 String group = "group1";
\r
50 ConsumerConnector cc = null;
\r
51 KafkaConsumer kafka = null;
\r
54 kafka = new KafkaConsumer(topic, group, id, cc);
\r
56 } catch (NullPointerException e) {
\r
59 } catch (NullPointerException e1) {
\r
60 // TODO Auto-generated catch block
\r
68 public void testGetCreateTimeMs() {
\r
70 String topic = "testTopic";
\r
71 String group = "group1";
\r
73 ConsumerConnector cc = null;
\r
75 KafkaConsumer kafka = null;
\r
78 kafka = new KafkaConsumer(topic, group, id, cc);
\r
81 } catch (NullPointerException e) {
\r
83 kafka.getCreateTimeMs();
\r
84 } catch (NullPointerException e1) {
\r
85 // TODO Auto-generated catch block
\r
90 String trueValue = "True";
\r
91 assertTrue(trueValue.equalsIgnoreCase("True"));
\r
96 public void testGetLastAccessMs() {
\r
98 String topic = "testTopic";
\r
99 String group = "group1";
\r
101 ConsumerConnector cc = null;
\r
103 KafkaConsumer kafka = null;
\r
106 kafka = new KafkaConsumer(topic, group, id, cc);
\r
109 } catch (NullPointerException e) {
\r
111 kafka.getLastAccessMs();
\r
112 } catch (NullPointerException e1) {
\r
113 // TODO Auto-generated catch block
\r
121 public void testNextMessage() {
\r
123 String topic = "testTopic";
\r
124 String group = "group1";
\r
126 ConsumerConnector cc = null;
\r
128 KafkaConsumer kafka = null;
\r
131 kafka = new KafkaConsumer(topic, group, id, cc);
\r
134 } catch (NullPointerException e) {
\r
136 kafka.nextMessage();
\r
137 } catch (NullPointerException e1) {
\r
138 // TODO Auto-generated catch block
\r
143 String trueValue = "True";
\r
144 assertTrue(trueValue.equalsIgnoreCase("True"));
\r
149 public void testGetOffset() {
\r
151 String topic = "testTopic";
\r
152 String group = "group1";
\r
154 ConsumerConnector cc = null;
\r
156 KafkaConsumer kafka = null;
\r
160 kafka = new KafkaConsumer(topic, group, id, cc);
\r
162 } catch (NullPointerException e) {
\r
166 } catch (NullPointerException e1) {
\r
167 // TODO Auto-generated catch block
\r
175 public void testCommitOffsets() {
\r
177 String topic = "testTopic";
\r
178 String group = "group1";
\r
180 ConsumerConnector cc = null;
\r
182 KafkaConsumer kafka = null;
\r
186 kafka = new KafkaConsumer(topic, group, id, cc);
\r
189 } catch (NullPointerException e) {
\r
191 kafka.commitOffsets();
\r
192 } catch (NullPointerException e1) {
\r
193 // TODO Auto-generated catch block
\r
201 public void testTouch() {
\r
203 String topic = "testTopic";
\r
204 String group = "group1";
\r
206 ConsumerConnector cc = null;
\r
208 KafkaConsumer kafka = null;
\r
212 kafka = new KafkaConsumer(topic, group, id, cc);
\r
215 } catch (NullPointerException e) {
\r
218 } catch (NullPointerException e1) {
\r
219 // TODO Auto-generated catch block
\r
224 String trueValue = "True";
\r
225 assertTrue(trueValue.equalsIgnoreCase("True"));
\r
230 public void testGetLastTouch() {
\r
232 String topic = "testTopic";
\r
233 String group = "group1";
\r
235 ConsumerConnector cc = null;
\r
237 KafkaConsumer kafka = null;
\r
241 kafka = new KafkaConsumer(topic, group, id, cc);
\r
244 } catch (NullPointerException e) {
\r
246 kafka.getLastTouch();
\r
247 } catch (NullPointerException e1) {
\r
248 // TODO Auto-generated catch block
\r
256 public void testClose() {
\r
258 String topic = "testTopic";
\r
259 String group = "group1";
\r
261 ConsumerConnector cc = null;
\r
263 KafkaConsumer kafka = null;
\r
267 kafka = new KafkaConsumer(topic, group, id, cc);
\r
270 } catch (NullPointerException e) {
\r
273 } catch (NullPointerException e1) {
\r
274 // TODO Auto-generated catch block
\r
282 public void testGetConsumerGroup() {
\r
284 String topic = "testTopic";
\r
285 String group = "group1";
\r
287 ConsumerConnector cc = null;
\r
289 KafkaConsumer kafka = null;
\r
293 kafka = new KafkaConsumer(topic, group, id, cc);
\r
296 } catch (NullPointerException e) {
\r
298 kafka.getConsumerGroup();
\r
299 } catch (NullPointerException e1) {
\r
300 // TODO Auto-generated catch block
\r
308 public void testGetConsumerId() {
\r
310 String topic = "testTopic";
\r
311 String group = "group1";
\r
313 ConsumerConnector cc = null;
\r
315 KafkaConsumer kafka = null;
\r
319 kafka = new KafkaConsumer(topic, group, id, cc);
\r
323 } catch (NullPointerException e) {
\r
325 kafka.getConsumerId();
\r
326 } catch (NullPointerException e1) {
\r
327 // TODO Auto-generated catch block
\r