Xu Xiong

Local E2E test works: ``` .venvxux-java-data% opensearch-benchmark execute-test --workload-repository=default --workload-revision=9f45b3683c01c0a2979f7f0edf3566362d54bbce --pipeline=benchmark-only --workload=geonames --target-host=127.0.0.1:9200 --workload-params '{"ingest_percentage":"1","bulk_size":"100","number_of_shards":"1","number_of_replicas":"0","ingestion_source_type": "kafka","ingestion_topic":"test","ingestion_bootstrap_servers":"localhost:34803"}' --test-procedure=polling-ingest-index-only --kill-running-processes ____ _____ __ ____ __ __ / __ \____ ___ ____ /...

@IanHoang, @gkamat, please take a look when you have time. thanks!

> @xuxiong1 Unittests are failing right now due to the following error: > > ``` > ERROR: Could not find a version that satisfies the requirement aiokafka>=0.12.0 (from opensearch-benchmark) (from...

local E2E test with telemetry enabled: ``` % opensearch-benchmark execute-test \ --workload-repository=default \ --workload-revision=51899e7b8b21f23b8050b5ad363c65e96d17d757 \ --pipeline=benchmark-only \ --workload=geonames \ --target-host=127.0.0.1:9200 \ --workload-params '{ "ingest_percentage": "5", "bulk_size": "1000", "number_of_shards": "1", "number_of_replicas":...

Hi @rishabh6788 , I updated the PR and resolved the lint errors, please take a look. Also I moved `RequestContextHolder` to a new context.py file to resolve the cyclic dependency...

@IanHoang @gkamat gentle ping here in case you missed.

> @xuxiong1 -- Looks like the latest test failure is related to this change > > ``` > org.opensearch.indices.recovery.RecoveryTests.testRecoveryTrimsLocalTranslogWithReadForward failed > > java.lang.AssertionError: NoOp{seqNo=26, primaryTerm=41, reason='filling gaps'} > Expected: >...