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

• Fix test case: actually use a test parameter

  miguno

  committedDec 3, 2014
  20a6559

Commits on Dec 2, 2014

• KafkaStormSpec: use our own embedded ZooKeeper instance instead of Storm's

  miguno

  committedDec 2, 2014
  095f146

• Squelch logging by org.apache.storm.zookeeper.server.NIOServerCnxnFactory in tests

  miguno

  committedDec 2, 2014
  a7ccc71

Commits on Sep 30, 2014

• Rename sparkConsumerParallelism to sparkProcessingParallelism to clarify meaning

  miguno

  committedSep 30, 2014
  b57c8bb

• Clarify repartition()

  miguno

  committedSep 30, 2014
  564e5d6

• Derive required #cores for Spark from #partitions of Kafka input topic

  miguno

  committedSep 30, 2014
  891d50b

• Add link to Tuning Guide

  miguno

  committedSep 30, 2014
  657c09d

• Increase test timeouts to help Travis CI builds

  miguno

  committedSep 30, 2014
  2b61fbf

Commits on Sep 29, 2014

• Clarify how to create map of topics

  miguno

  committedSep 29, 2014
  09cca52

• 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

• Fix code comment

  miguno

  committedSep 29, 2014
  26c6c9d

• Clarify comment on parallelism

  miguno

  committedSep 29, 2014
  8dc4afe

• Clarify test output

  miguno

  committedSep 29, 2014
  57da5f7

• Simplify log4j.properties

  miguno

  committedSep 29, 2014
  f1abf54

• Don't shorten classnames in test logs

  miguno

  committedSep 29, 2014
  784077b

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

  miguno

  committedSep 29, 2014
  83a389a

• Remove METRICS logging appender

  miguno

  committedSep 29, 2014
  d19c408

• 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

• Squelch error output of AvroKafkaSinkBolt in tests

  miguno

  committedSep 17, 2014
  9d46db7

• Squelch error output of AvroDecoderBolt in tests

  miguno

  committedSep 17, 2014
  3765c33

• Squelch error messages logged by org.apache.curator.framework.imps.CuratorFrameworkImpl

  miguno

  committedSep 17, 2014
  8e66b87

• 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

• Disable ZK retries in Kafka spout for our Kafka/Storm test topology

  miguno

  committedSep 17, 2014
  08bdaeb

Commits on Aug 27, 2014

• Squelch test output of kafka.network.Processor

  miguno

  committedAug 27, 2014
  3608502

Commits on Aug 18, 2014

• Add log4j.properties to src/main/resources/

  miguno

  committedAug 18, 2014
  5831f5d

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

• Clarify test variables

  miguno

  committedJul 11, 2014
  9ec6e74

• Remove redundant braces

  miguno

  committedJul 11, 2014
  03458d4

Pagination

PreviousNext