gAmUssA

#Using wireshark to sniff kafka messages

Install the latest WireShark application

 sudo add-apt-repository ppa:wireshark-dev/stable
 sudo apt-get update
 sudo apt-get install wireshark

gAmUssA

# a comma separated list of the the ccloud broker endpoints. e.g.
bootstrap.servers=r0.great-app.confluent.aws.prod.cloud:9092,r1.great-app.confluent.aws.prod.cloud:9093,r2.great-app.confluent.aws.prod.cloud:9094
ksql.sink.replicas=3
replication.factor=3
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=\
    org.apache.kafka.common.security.plain.PlainLoginModule required \
    username="<confluent cloud access key>" \
    password="<confluent cloud secret>";

gAmUssA

package com.nyjavasig.how.hazelcast.demo;

import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.LineNumberReader;
import java.util.HashMap;
import java.util.Map;
import java.util.regex.Pattern;

public class WordUtil {

gAmUssA

<?xml version="1.0" encoding="UTF-8"?>
<hazelcast
        xsi:schemaLocation="http://www.hazelcast.com/schema/config http://www.hazelcast.com/schema/config/hazelcast-config-3.8.xsd"
        xmlns="http://www.hazelcast.com/schema/config"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

    

</hazelcast>

gAmUssA

package com.hazelcast.zookeeper;


import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.x.discovery.ServiceDiscovery;
import org.apache.curator.x.discovery.ServiceDiscoveryBuilder;
import org.apache.curator.x.discovery.ServiceInstance;

gAmUssA

Set<Integer> set = new HashSet<>(Arrays.asList(1,2,3,4,5))
System.out.println(set);
/exit

gAmUssA

Asciidoctor EPUB3 1.5.0.dev using Asciidoctor 1.5.3 [http://asciidoctor.org]
Runtime Environment (ruby 1.9.3p484 (2013-11-22 revision 43786) [x86_64-darwin13.3.0]) (lc:UTF-8 fs:UTF-8 in:- ex:UTF-8)

/usr/local/Cellar/rbenv/0.4.0/versions/1.9.3-p484/lib/ruby/gems/1.9.1/gems/asciidoctor-epub3-1.5.0.dev/lib/asciidoctor-epub3/converter.rb:336:in `listing': undefined method `gsub' for nil:NilClass (NoMethodError)
	from /usr/local/Cellar/rbenv/0.4.0/versions/1.9.3-p484/lib/ruby/gems/1.9.1/gems/asciidoctor-epub3-1.5.0.dev/lib/asciidoctor-epub3/converter.rb:89:in `convert'
	from /usr/local/opt/rbenv/versions/1.9.3-p484/lib/ruby/gems/1.9.1/gems/asciidoctor-1.5.3/lib/asciidoctor/abstract_block.rb:71:in `convert'
	from /usr/local/opt/rbenv/versions/1.9.3-p484/lib/ruby/gems/1.9.1/gems/asciidoctor-1.5.3/lib/asciidoctor/abstract_block.rb:80:in `block in content'
	from /usr/local/opt/rbenv/versions/1.9.3-p484/lib/ruby/gems/1.9.1/gems/asciidoctor-1.5.3/lib/asciidoctor/abstract_block.rb:80:in `map'
	from /usr/local/opt/rbenv/

gAmUssA

-- Adapted from these sources:
-- http://peterdowns.com/posts/open-iterm-finder-service.html
-- https://gist.github.com/cowboy/905546
-- 
-- Modified to work with files as well, cd-ing to their container folder
-- Modified to work with iTerm 2 night builds https://iterm2.com/applescript.html
on run {input, parameters}
	tell application "Finder"
		set my_file to first item of input
		set filetype to (kind of (info for my_file))

gAmUssA

#!/bin/sh

version=3.5
releaseRepo=https://repository-hazelcast-l337.forge.cloudbees.com/release/com/hazelcast
snapshotRepo=https://repository-hazelcast-l337.forge.cloudbees.com/snapshot/com/hazelcast
groupId="com.hazelcast"
artifactId="hazelcast-enterprise"
clientArtifactId="hazelcast-enterprise-client"

# install Hazelcast Enterprise

gAmUssA

import javax.script.ScriptEngine
import javax.script.ScriptEngineFactory
import javax.script.ScriptEngineManager;

//System.properties.each { k, v -> println("$k = $v") }
println System.properties['java.runtime.version']
println "---------------------------------"
ScriptEngineManager manager = new ScriptEngineManager()
ScriptEngine nashorn = manager.getEngineByName("nashorn")
if (nashorn != null) {