Skip to content

Instantly share code, notes, and snippets.

@srishtyagrawal

srishtyagrawal/storm-kafka

Created May 9, 2017 18:28
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save srishtyagrawal/e068bd934094d685a08ece5924e3e71f to your computer and use it in GitHub Desktop.
Save srishtyagrawal/e068bd934094d685a08ece5924e3e71f to your computer and use it in GitHub Desktop.
Download ZIP
Raw
storm-kafka
o.a.s.k.KafkaUtils [INFO] Task [2/16] assigned [Partition{host=localhost:9092, topic=topic8, partition=1}]
o.a.s.k.ZkCoordinator [INFO] Task [2/16] Deleted partition managers: []
o.a.s.k.ZkCoordinator [INFO] Task [2/16] New partition managers: [Partition{host=localhost:9092, topic=topic8, partition=1}]
o.a.s.k.PartitionManager [INFO] Read partition information from: /consumers/consumer-topic8/partition_1 --> null
o.a.s.k.PartitionManager [INFO] No partition information found, using o.a.s.k.PartitionManager [INFO] Starting Kafka localhost Partition{host=localhost:9092, topic=topic8, partition=1} from offset 14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment