Skip to content

Commit 07b6077

Browse files
authored
Merge pull request zendesk#841 from Darhazer/fix-checking-last-message-time
Fix getting last message time
2 parents d43c55c + 526bb07 commit 07b6077

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/kafka/consumer.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -316,7 +316,7 @@ def each_batch(min_bytes: 1, max_bytes: 10485760, max_wait_time: 1, automaticall
316316
topic: batch.topic,
317317
partition: batch.partition,
318318
last_offset: batch.last_offset,
319-
last_create_time: batch.messages.last.try(:create_time),
319+
last_create_time: batch.messages.last && batch.messages.last.create_time,
320320
offset_lag: batch.offset_lag,
321321
highwater_mark_offset: batch.highwater_mark_offset,
322322
message_count: batch.messages.count,

0 commit comments

Comments
 (0)