Skip to content

Commit

Permalink
Add pulsar plugin
Browse files Browse the repository at this point in the history
  • Loading branch information
CodePrometheus committed May 5, 2024
1 parent 60db6a0 commit e48124e
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 3 deletions.
3 changes: 2 additions & 1 deletion tests/plugin/data/sw_pulsar/docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,8 @@ services:
image: apachepulsar/pulsar:3.2.0
hostname: pulsar-server
ports:
- "6650:6650"
- 6650:6650
- 8080:8080
networks:
- beyond
healthcheck:
Expand Down
2 changes: 1 addition & 1 deletion tests/plugin/data/sw_pulsar/services/consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
if __name__ == '__main__':
import pulsar

client = pulsar.Client('pulsar://pulsar-server:6650')
client = pulsar.Client(service_url='pulsar://pulsar-server:6650')
consumer = client.subscribe('sw-topic', 'sw-subscription')

while True:
Expand Down
2 changes: 1 addition & 1 deletion tests/plugin/data/sw_pulsar/services/producer.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
from pulsar import BatchingType

app = Flask(__name__)
client = pulsar.Client('pulsar://pulsar-server:6650')
client = pulsar.Client(service_url='pulsar://pulsar-server:6650')
producer = client.create_producer(
'sw-topic',
block_if_queue_full=True,
Expand Down

0 comments on commit e48124e

Please sign in to comment.