# How to use 'Esbolt' in Storm Trident

**URL:** <https://discuss.elastic.co/t/how-to-use-esbolt-in-storm-trident/27941>\
**Category:** Elasticsearch\
**Tags:** es-hadoop\
**Created:** [August 24, 2015, 11:30am UTC](https://discuss.elastic.co/t/how-to-use-esbolt-in-storm-trident/27941 "2015-08-24T11:30:52Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![Maisy](https://avatars.discourse-cdn.com/v4/letter/m/b5ac83/32.png) [@Maisy](https://discuss.elastic.co/u/Maisy)\
**Post date:** [August 24, 2015, 11:30am UTC](https://discuss.elastic.co/t/how-to-use-esbolt-in-storm-trident/27941/1 "2015-08-24T11:30:52Z")

</div>

I used EsBolt at storm topology like this:  
builder.setBolt(topic + "WriteEsbolt", new EsBolt("{index}/{type}")

but I cannot use that at storm Trident..  
Trident use not bolt but operator..  
How can I insert tuple data in Elastic search?

---

<div class="post-metadata">

**Author:** ![eliasah](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/eliasah/32/34741_2.png) [@eliasah](https://discuss.elastic.co/u/eliasah)\
**Post date:** [August 24, 2015, 12:20pm UTC](https://discuss.elastic.co/t/how-to-use-esbolt-in-storm-trident/27941/2 "2015-08-24T12:20:07Z")

</div>

Can you try to give more details about you are doing? It's not very clear.

---

<div class="post-metadata">

**Author:** ![Maisy](https://avatars.discourse-cdn.com/v4/letter/m/b5ac83/32.png) [@Maisy](https://discuss.elastic.co/u/Maisy)\
**Post date:** [August 24, 2015, 12:30pm UTC](https://discuss.elastic.co/t/how-to-use-esbolt-in-storm-trident/27941/3 "2015-08-24T12:30:06Z")

</div>

I implemented storm topology like this(using spout, bolt)

```
builder.setSpout("logSpout", createKafkaSpout(topicNm), kafkaSpoutNum);
builder.setBolt("PreProcessing", new LogPreprocessing(), 3).shuffleGrouping("logSpout");
builder.setBolt("WriteEsbolt", new EsBolt("{indexname}/{typename}"), writeEsBoltNum).shuffleGrouping("PreProcessing", "esTuple") .addConfiguration(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, tickFreqSecs);

```

But, I changed this topology using Trident.... I cannot use EsBolt()

```
  TridentTopology topology = new TridentTopology();
  Stream spoutStreamAccess = topology.newStream("str", createKafkaSpout(topicNm));
  Stream parsedStream = spoutStreamAccess.each(new Fields("str"), new LogPreprocessing(), new Fields("fileInfo","fileDtm", "fileCnts", "fileName", "esTuple"));
  parsedStream.each(new Fields("esTuple"), new EsBolt("{indexname}/{typename}"))
```

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 6, 2017, 1:27pm UTC](https://discuss.elastic.co/t/how-to-use-esbolt-in-storm-trident/27941/4 "2017-07-06T13:27:38Z")

</div>