Skip to content

Commit 526bb07

Browse files
author
Maxim Krizhanovski
committed
Fix getting last message time
`try` is from ActiveSupport which is a development dependency. Use a simple nil check instead.
1 parent d43c55c commit 526bb07

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)