victorarias’s gists

victorarias / boom.sh

Created March 27, 2018 20:40

	20:20:43 ~$ irb
	irb(main):001:0> load "boom.rb"
	=> true
	irb(main):002:0> load "boom.rb"
	Traceback (most recent call last):
	4: from /usr/local/bin/irb:11:in `<main>'
	3: from (irb):2
	2: from (irb):2:in `load'
	1: from boom.rb:1:in `<top (required)>'
	TypeError (superclass mismatch for class Country)

victorarias / boom.rb

Created March 27, 2018 20:39

	class Country < Struct.new(:request, :ip, :country_code, :country_code2, :country_code3, :country_name, :continent_code)
	end

victorarias / coutry_line.rb

Last active March 27, 2018 20:51

	class Country < Struct.new(:request, :ip, :country_code, :country_code2, :country_code3, :country_name, :continent_code)

victorarias / java_consumer_logs.log

Created March 21, 2018 20:34

	Starting polling from Java bids consumer:
	key: 4, payload: {"bid_amount":4,"producer_id":"producer_1"}
	key: 9, payload: {"bid_amount":9,"producer_id":"producer_2"}
	key: 6, payload: {"bid_amount":12,"producer_id":"producer_1"}
	key: 9, payload: {"bid_amount":18,"producer_id":"producer_2"}
	key: 5, payload: {"bid_amount":15,"producer_id":"producer_2"}
	key: 8, payload: {"bid_amount":24,"producer_id":"producer_1"}
	key: 2, payload: {"bid_amount":8,"producer_id":"producer_1"}
	key: 6, payload: {"bid_amount":24,"producer_id":"producer_2"}
	key: 2, payload: {"bid_amount":10,"producer_id":"producer_1"}

victorarias / rb_producer_logs.log

Created March 21, 2018 20:33

	19:54:19 kafka_rb$ be ruby producer.rb
	producer_2: Starting to publish messages...
	producer_2: Publishing message with key=9 message={"bid_amount":9,"producer_id":"producer_2"}
	producer_1: Starting to publish messages...
	producer_1: Publishing message with key=4 message={"bid_amount":4,"producer_id":"producer_1"}
	producer_1: Publishing message with key=6 message={"bid_amount":12,"producer_id":"producer_1"}
	producer_2: Publishing message with key=9 message={"bid_amount":18,"producer_id":"producer_2"}
	producer_2: Publishing message with key=5 message={"bid_amount":15,"producer_id":"producer_2"}
	producer_1: Publishing message with key=8 message={"bid_amount":24,"producer_id":"producer_1"}
	producer_1: Publishing message with key=2 message={"bid_amount":8,"producer_id":"producer_1"}

victorarias / java_consumer.java

Last active March 21, 2018 20:31

	public static void main(String[] args) {
	KafkaConsumer consumer = new KafkaConsumer(getProperties());

	consumer.subscribe(Collections.singletonList("bids"));

	System.out.println("Starting polling from Java bids consumer:");

	while(true) {
	ConsumerRecords<String, String> records = consumer.poll(100);

victorarias / rb_producer.rb

Created March 21, 2018 20:29

	require "kafka"
	require "json"

	class Producer
	def initialize(producer_id)
	@producer_id = producer_id
	@kafka = Kafka.new(["localhost:9092"], client_id: @producer_id)
	@count = 0
	end

victorarias / java_consumer.java

Last active March 21, 2018 20:17

Ruby + Java via Kafka integration

	public static void main(String[] args) {
	KafkaConsumer consumer = new KafkaConsumer(getProperties());

	consumer.subscribe(Collections.singletonList("bids"));

	System.out.println("Starting polling from Java bids consumer:");

	while(true) {
	ConsumerRecords<String, String> records = consumer.poll(100);

victorarias / test.rb

Created October 8, 2014 13:00

	gem "rails", "3.2.19"

	require "rails"
	require "action_controller/railtie"

	class TestApp < Rails::Application
	config.root = File.dirname(__FILE__)
	config.session_store :cookie_store, key: "cookie_store_key"
	config.secret_token = "1111111111111111111111111111111111111111111111111111111111111111111111111secret_token"
	config.secret_key_base = "secret_key_base"

victorarias / gist:bfa66a3e90d32437a1d1

Created September 25, 2014 21:53

	# Activate the gem you are reporting the issue against.
	gem 'rails', '4.0.0'

	require 'rails'
	require 'action_controller/railtie'

	class TestApp < Rails::Application
	config.root = File.dirname(__FILE__)
	config.session_store :cookie_store, key: 'cookie_store_key'
	config.secret_token = 'secret_token'

Victor Arias victorarias