File tree Expand file tree Collapse file tree 2 files changed +7
-0
lines changed
instrumentation/rdkafka/test/opentelemetry/instrumentation/rdkafka/patches Expand file tree Collapse file tree 2 files changed +7
-0
lines changed Original file line number Diff line number Diff line change 3333
3434 describe '#each' do
3535 it 'traces each call' do
36+ skip "#{ Rdkafka ::VERSION } is not supported" unless instrumentation . installed?
37+
3638 rand_hash = SecureRandom . hex ( 10 )
3739 topic_name = "consumer-patch-trace-#{ rand_hash } "
3840 config = { 'bootstrap.servers' : "#{ host } :#{ port } " }
112114 end
113115
114116 it 'encodes messages keys depending on input format' do
117+ skip "#{ Rdkafka ::VERSION } is not supported" unless instrumentation . installed?
118+
115119 rand_hash = SecureRandom . hex ( 10 )
116120 topic_name = "consumer-patch-trace-#{ rand_hash } "
117121 config = { 'bootstrap.servers' : "#{ host } :#{ port } " }
164168
165169 describe '#each_batch' do
166170 it 'traces each_batch call' do
171+ skip "#{ Rdkafka ::VERSION } is not supported" unless instrumentation . installed?
172+
167173 rand_hash = SecureRandom . hex ( 10 )
168174 topic_name = "consumer-patch-batch-trace-#{ rand_hash } "
169175 config = { 'bootstrap.servers' : "#{ host } :#{ port } " }
Original file line number Diff line number Diff line change 3232
3333 describe 'tracing' do
3434 it 'traces sync produce calls' do
35+ skip "#{ Rdkafka ::VERSION } is not supported" unless instrumentation . installed?
3536 topic_name = 'producer-patch-trace'
3637 config = { 'bootstrap.servers' : "#{ host } :#{ port } " }
3738
You can’t perform that action at this time.
0 commit comments