Question: If a kakfa topic has more than one partition , in java , those many consumer instances/threads would be instantiated at consumer side.

How it could be handled in spark-streaming consumer side ? I dont find much information regarding the same. Any sample for the same i.e. invoking multiple consumers at spark-streaming-consumer of a topic.

Any design suggestion/examples around would be highly thankful.

Regards,
Shyam

Answer: 
Update `Calligraphy` to newest version to solve this problem:
Link: <https://github.com/InflationX/Calligraphy/issues/35>

More specifically, both Calligraphy **and** ViewPump need to be updated:

```
implementation 'io.github.inflationx:calligraphy3:3.1.1'
implementation 'io.github.inflationx:viewpump:2.0.3'

```

Migrating from Calligraphy 2 to 3 requires some code changes; see examples in [Calligraphy 3 README](https://github.com/InflationX/Calligraphy).
```
Please foloow this below steps.
1> First of all check build.gradle(:app) file
2> If you are using  this below library:
implementation 'uk.co.chrisjenx:calligraphy:2.3.0'
3> Update this " implementation 'uk.co.chrisjenx:calligraphy:2.3.0' " library with this below library.
implementation 'io.github.inflationx:viewpump:2.0.3'
implementation 'io.github.inflationx:calligraphy3:3.1.1'
4> In project where You use this below code :
@Override
    protected void attachBaseContext(Context newBase) {
        super.attachBaseContext(CalligraphyContextWrapper.wrap(newBase));
    }

5> Update it with this below code:

   @Override
    protected void attachBaseContext(Context newBase) {
        super.attachBaseContext(ViewPumpContextWrapper.wrap(newBase));
    }

```