Skip to content

Instantly share code, notes, and snippets.

https://auctionet.com/de?gclid=CKK21fmSuLwCFSoEwwodOlkABg
http://auctionet.com/search?is=&q=???ldre+m???stare+-hundra&utf8=?&utm_medium=campaign&utm_source=campaign293&utm_campaign=Kampanj+293%3A+%C3%84ldre+m%C3%A4stare
unless File.exist?('Gemfile')
File.write('Gemfile', <<-GEMFILE)
source 'https://rubygems.org'
gem 'rails', github: 'rails/rails'
gem 'arel', github: 'rails/arel'
gem 'rack', github: 'rack/rack'
gem 'i18n', github: 'svenfuchs/i18n'
GEMFILE
system 'bundle'
# 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'
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
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);
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
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);
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"}
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"}
class Country < Struct.new(:request, :ip, :country_code, :country_code2, :country_code3, :country_name, :continent_code)