joeljames

@Slf4j
public class KafkaConsumerWithThreads {
    private static final AtomicBoolean shutdownRequested = new AtomicBoolean(false);
    private static final List<String> topics = List.of("my-topic");
    private static final int noOfWorkerThreads = 3;

    public static void main(String[] args) {
        ExecutorService service = Executors.newFixedThreadPool(noOfWorkerThreads);
        IntStream.range(0, noOfWorkerThreads)
                .forEach(i -> service.execute(getRunnableTask()));

joeljames

@Slf4j
public class KafkaProducerApp {
    private static final String topic = "my-topic";

    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092,localhost:9093,localhost:9094");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        

joeljames

## Push to test server
## Register ##
python setup.py register -r pypitest
## Upload ##
python setup.py sdist upload -r pypitest

## Push to main server
## Register ##
python setup.py register -r pypi
## Upload ##

joeljames

{% block header %}
  <h1>Application Queue Status</h1>

  <dl>
    {% for name, size in queue_summary.items %}
      <dt>Queue Name: {{ name }}</dt>
      <dd>Queue Size: {{ size }}</dd>
      </br>
    {% endfor %}
  </dl>

joeljames

from collections import defaultdict

from django.views.generic.base import TemplateResponseMixin, View

from rest_framework import status
from annoying.functions import get_config
from redis import StrictRedis


__all__ = [

joeljames

# ----------------------------------------------------------------------------
# Health monitoring
# --------------------------------------------------------

REDIS_URL = environ.get('REDIS_URL', '')

# Queue Heath Monitoring
# Allowable max queue size to monitor queue health.
ALLOWABLE_MAX_QUEUE_SIZE = int(
    environ.get(

joeljames

from django.conf.urls import url

from health.views import StatusQueueView


urlpatterns = [
    url(r'^queue/$',
        StatusQueueView.as_view(),
        name='status-queue'),
]

joeljames

Keybase proof

I hereby claim:

• I am joeljames on github.
• I am joeljames (https://keybase.io/joeljames) on keybase.
• I have a public key whose fingerprint is F0B4 996B 8EED 7CA5 5512 7740 2449 64A7 1F03 A944

To claim this, I am signing this object:

joeljames

#!/bin/sh

#Pre commit hook that prevents code from being commited if tests fails or if code has break points.

# Stash the changes that has not been added
git stash -q --keep-index

echo "Testing....."
python manage.py test
TEST_RESULT=$?