I am trying to use kinesis spout in my storm topology but when i am runnign my topology there is connection exception in Zookeeperstatemanager.java(104).This is my sample kinesisSpoutconfig which i am using
topologyName = SampleTopology
streamName = AssociatesRealTimeClicks-NA
Use TRIM_HORIZON to start processing from the oldest available record in the shard (if checkpoint is not present)
I am trying to use kinesis spout in my storm topology but when i am runnign my topology there is connection exception in Zookeeperstatemanager.java(104).This is my sample kinesisSpoutconfig which i am using topologyName = SampleTopology streamName = AssociatesRealTimeClicks-NA
Use TRIM_HORIZON to start processing from the oldest available record in the shard (if checkpoint is not present)
initialPositionInStream = LATEST recordRetryLimit = 3 zookeeperEndpoint = localhost:2181
Prefix/path for storing spout state in Zookeeper
zookeeperPrefix = kinesis_spout SymmetricKeyMaterialSetName = com.amazon.associates.analytics.test.credentialsodin redisEndpoint = redis-cluster-endpoint regionName = us-east-1