169.254.169.254
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
kafka-console-producer --topic conor-topic --broker-list kafka-0:9092 --property "parse.key=true" --property "key.separator=:" | |
1:{"product_id":"1","type":"jam"} | |
2:{"product_id":"2","type":"joe"} | |
3:{"product_id":"3","type":"hey"} | |
4:{"product_id":"4","type":"ram"} | |
5:{"product_id":"5","type":"goo"} | |
6:{"product_id":"6","type":"dam"} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
echo "exclude.internal.topics=false" > /tmp/consumer.config | |
#Only consume the latest consumer offsets | |
./kafka-console-consumer.sh --consumer.config /tmp/consumer.config \ | |
--formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" \ | |
--bootstrap-server ${BOOTSTRAP_SERVER} --topic __consumer_offsets |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
pt-get -qq update | |
apt-get remove apt-listchanges | |
apt-get install curl |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# Install go/golang with homebrew | |
brew install go --cross-compile-common | |
# Set following env variables in ~/.bashrc or ~/.zshrc | |
export GOPATH=$HOME/golang | |
export GOROOT=/usr/local/opt/go/libexec | |
export GOBIN=$GOPATH/bin | |
export PATH=$PATH:$GOPATH | |
export PATH=$PATH:$GOROOT/bin |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
"\e\e[C": forward-word | |
"\e\e[D": backward-word |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
realm=Sonatype Nexus | |
host=127.0.0.1 | |
user=admin | |
password=admin123 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import org.scalatest.FunSpec | |
import scala.collection.mutable.Stack | |
class ExampleSpec extends FunSpec { | |
describe("A Stack") { | |
it("should pop values in last-in-first-out order") { | |
val stack = new Stack[Int] | |
stack.push(1) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
val sc: SparkContext // An existing SparkContext. | |
val sqlContext = new org.apache.spark.sql.SQLContext(sc) | |
// Create the DataFrame | |
val df = sqlContext.read.json("examples/src/main/resources/people.json") | |
// Show the content of the DataFrame | |
df.show() | |
// age name | |
// null Michael |
I hereby claim:
- I am conorfennell on github.
- I am conorfennell (https://keybase.io/conorfennell) on keybase.
- I have a public key whose fingerprint is BEC2 979F 714E 8062 9451 FFC7 EC51 456C AFF9 3BBC
To claim this, I am signing this object:
NewerOlder