Skip to content

Commit 1c6a738

Browse files
committed
updated testcases
1 parent ad9b600 commit 1c6a738

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

src/main/java/com/splunk/kafka/connect/SplunkSinkTask.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -579,6 +579,7 @@ private void timestampExtraction(Event event) {
579579
}
580580
} else {
581581
SimpleDateFormat df = new SimpleDateFormat(connectorConfig.timestampFormat);
582+
df.setTimeZone(TimeZone.getTimeZone("UTC"));
582583
Date date;
583584
try {
584585
if(!connectorConfig.timeZone.isEmpty())

src/test/java/com/splunk/kafka/connect/SplunkSinkTaskTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -286,7 +286,7 @@ public void checkExtractedTimestampWithTimezone() {
286286
config.put(SplunkSinkConnectorConfig.ENABLE_TIMESTAMP_EXTRACTION_CONF, String.valueOf(true));
287287
config.put(SplunkSinkConnectorConfig.REGEX_CONF, "\\\"REQ_TIME\\\":\\s*\\\"(?<time>.*?)\"");
288288
config.put(SplunkSinkConnectorConfig.TIMESTAMP_FORMAT_CONF, "yyyyMMddHHmmssSSS");
289-
config.put(SplunkSinkConnectorConfig.TIMESTAMP_TIMEZONE_CONF, "Asis/Seoul");
289+
config.put(SplunkSinkConnectorConfig.TIMESTAMP_TIMEZONE_CONF, "Asia/Seoul");
290290
HecMock hec = new HecMock(task);
291291
hec.setSendReturnResult(HecMock.success);
292292
task.setHec(hec);
@@ -300,7 +300,7 @@ public void checkExtractedTimestampWithTimezone() {
300300
Iterator<Event> iterator = event_list.listIterator() ;
301301
Event event = iterator.next();
302302

303-
Assert.assertEquals(1.693834216993E9, event.getTime(), 0);
303+
Assert.assertEquals(1.693801816993E9, event.getTime(), 0);
304304
break;
305305
}
306306
task.stop();
@@ -331,7 +331,7 @@ public void checkExtractedTimestampWithoutTimezoneAsUTC() {
331331
Iterator<Event> iterator = event_list.listIterator() ;
332332
Event event = iterator.next();
333333

334-
Assert.assertEquals(1.693801816993E9, event.getTime(), 0);
334+
Assert.assertEquals(1.693834216993E9, event.getTime(), 0);
335335
break;
336336
}
337337
task.stop();

0 commit comments

Comments
 (0)