Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- SERVICE_URL: "pulsar://pulsar:6650"
- CONSUME_TOPIC: "persistent://public/default/parsed-tweets-.*"
- PRODUCE_TOPIC: "persistent://public/default/hashtags"
- SUBSCRIPTION: "tweet-parsing"
- SLEEP_TIME: 20 # Sleep time BEFORE attempting to connect to a topic
- RETRIES: 5 # Number of attempts when connecting to a topic
- ASYNC: 1 # Use Pulsar async streaming (1:True, 0:False)
- STAT_RATE: 10000 # Rate at which stats are logged (stats logged per X messages received)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement