Skip to content

Commit 9ed5ecc

Browse files
author
elena
committed
add max_wait_time to addr_reader for fetcher
1 parent c0c7785 commit 9ed5ecc

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

.gitignore

-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
/spec/reports/
99
/tmp/
1010
.env
11-
.idea/
1211
*.log
1312
*.swp
1413
.byebug_history

lib/kafka/fetcher.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44

55
module Kafka
66
class Fetcher
7-
attr_reader :queue
7+
attr_reader :queue, :max_wait_time
88

99
def initialize(cluster:, logger:, instrumenter:, max_queue_size:, group:)
1010
@cluster = cluster

0 commit comments

Comments
 (0)