Skip to content

Instantly share code, notes, and snippets.

View Fluxx's full-sized avatar

Jeff Pollard Fluxx

View GitHub Profile
src/main/java/com/pinterest/secor/common/KafkaClient.java:109: throw new RuntimeException("Error fetching offset data. Reason: " +
src/main/java/com/pinterest/secor/common/KafkaClient.java:130: throw new RuntimeException("Error fetching offset data. Reason: " +
src/main/java/com/pinterest/secor/common/KafkaClient.java:178: throw new RuntimeException("Expected one metadata for topic " + topic + " found " +
src/main/java/com/pinterest/secor/common/LogFilePath.java:83: throw new RuntimeException("Unable to find mdt digest.", e);
src/main/java/com/pinterest/secor/common/LogFilePath.java:184: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/common/SecorConfig.java:50: throw new RuntimeException("Error loading configuration from " + configProperty);
src/main/java/com/pinterest/secor/common/SecorConfig.java:440: throw new RuntimeException("secor.file.reader.Delimiter length can not be greater than 1 character");
src/
@Fluxx
Fluxx / mountainneering-2017.md
Last active March 16, 2017 01:50
Mountaineering objectives 2017

2017 Mountaineering

Here was what I think would be a good season of mountaineering for us. High level details on the trips is below, plus some open questions at the bottom.

Trips

  • Castle Peak :: Friday 2/17/2017 - Monday 2/20/2017 (presidents day) confirmed
  • Lassen Peak :: Thursday 3/23/2017 - Sunday 3/26/2017 confirmed
  • Matterhorn Peak :: Friday 4/21/2017 - Sunday 4/23/2017
  • Dana Couloir :: Saturday 5/27/2017 - Sunday 5/28/2017
diff --git a/src/main/java/com/pinterest/secor/common/KafkaClient.java b/src/main/java/com/pinterest/secor/common/KafkaClient.java
index 3fe96a2..d7061dc 100644
--- a/src/main/java/com/pinterest/secor/common/KafkaClient.java
+++ b/src/main/java/com/pinterest/secor/common/KafkaClient.java
@@ -131,8 +131,11 @@ public class KafkaClient {
ByteBuffer payload = messageAndOffset.message().payload();
byte[] payloadBytes = new byte[payload.limit()];
payload.get(payloadBytes);
+ ByteBuffer key = messageAndOffset.message().key();
+ byte[] keyBytes = new byte[key.limit()];
class Foo(object):
def bar(func):
def inner(self):
return func(self)
return inner
@bar
def baz(self):
print 'baz'
@Fluxx
Fluxx / -
Created November 5, 2013 23:53
_______________
< PLATFORM TEAM >
---------------
\ ,+*^^*+___+++_
\ ,*^^^^ )
\ _+* ^**+_
\ +^ _ _++*+_+++_, )
_+^^*+_ ( ,+*^ ^ \+_ )
{ ) ( ,( ,_+--+--, ^) ^\
{ (@) } f ,( ,+-^ __*_*_ ^^\_ ^\ )
@Fluxx
Fluxx / foo.py
Last active December 25, 2015 13:19
from datetime import datetime
class Person(object):
pass
person = Person()
###############################################################################
# Needless local variables
###############################################################################
# bad
def foo():
bar = 1
return bar
# good
# bad
def foo():
bar = 1
return bar
# good
def foo():
return 1
@Fluxx
Fluxx / barf.py
Created September 20, 2013 22:16
How did this get here, I'm no good with computers
@Fluxx
Fluxx / europe
Created September 11, 2013 19:07
# <pre>
# This file is in the public domain, so clarified as of
# 2009-05-17 by Arthur David Olson.
# This data is by no means authoritative; if you think you know better,
# go ahead and edit the file (and please send any changes to
# tz@iana.org for general use in the future).
# From Paul Eggert (2006-03-22):
# A good source for time zone historical data outside the U.S. is