Commits

Breadcrumbs

History for

ondevelop

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 3, 2014

• Don't shadow an outer variable

  miguno

  committedDec 3, 2014
  29671be

Commits on Sep 29, 2014

• Use Int instead of Integer to configure #partitions and replication factor

  miguno

  committedSep 29, 2014
  3f476ae

• Use () to call side-effecting method

  miguno

  committedSep 29, 2014
  cb2efad

• Add Spark Streaming example that reads from Kafka and writes to Kafka

  miguno

  committedSep 29, 2014
  83a389a

• Move Storm-related classes to sub-packages

  miguno

  committedSep 29, 2014
  6a8a617

Commits on Sep 26, 2014

• Improve and consolidate the Kafka + ZooKeeper setup

  miguno

  committedSep 26, 2014
  70dad90

• Add createTopic() method

  miguno

  committedSep 26, 2014
  a521b98

Commits on Sep 17, 2014

• Add port details to log messages of embedded Kafka and ZooKeeper

  miguno

  committedSep 17, 2014
  5dd6afc

• Consolidate logging to use our own Logging traits (based on logback)

  miguno

  committedSep 17, 2014
  efde9df

Commits on Aug 14, 2014

• Remove type annotations for Injection's

  miguno

  committedAug 14, 2014
  de6eac4

Commits on Jul 11, 2014

• Rename KafkaConsumer to KafkaConsumerApp

  miguno

  committedJul 11, 2014
  a6be1f2

• Reformat code

  miguno

  committedJul 11, 2014
  f82c9c6

Commits on Jul 2, 2014

• Fix generation of path to temporary Kakfa data log directory (log.dirs)

  miguno

  committedJul 2, 2014
  a93d7d9

• Rename private method to match actual code

  miguno

  committedJul 2, 2014
  174ca58

Commits on Jun 30, 2014

• Auto-format code

  miguno

  committedJun 30, 2014
  9b16e9e

• KafkaEmbedded: use randomized local log.dirs, and remove it on shutdown

  miguno

  committedJun 30, 2014
  ec2daae

• Expose hostname and port of ZooKeeperEmbedded

  miguno

  committedJun 30, 2014
  54ac9e1

• Explicitly define return type of connectString

  miguno

  committedJun 30, 2014
  3b875c9

• ZooKeeperEmbedded: set default port to 2181

  miguno

  committedJun 30, 2014
  6dd9046

• Use Storm 0.9.2

  miguno

  committedJun 30, 2014
  ef3a727

Commits on Jun 17, 2014

• Explicitly return Unit value to prevent scalac warnings

  miguno

  committedJun 17, 2014
  f649480

Commits on Jun 13, 2014

• AvroKafkaSinkBolt should not declare any output fields because it writes

  miguno

  committedJun 13, 2014
  d36d1a4

Commits on May 28, 2014

• Add shutdown() method to KafkaProducerApp

  miguno

  committedMay 28, 2014
  62bf628

Commits on May 23, 2014

• Initial commit

  

  Michael G. Noll

  committedMay 23, 2014
  a2806fe

Loading