# Schema Registry integration with Logstash kafka input plugin

**URL:** <https://discuss.elastic.co/t/schema-registry-integration-with-logstash-kafka-input-plugin/335431>\
**Category:** Logstash\
**Created:** [June 7, 2023, 10:41am UTC](https://discuss.elastic.co/t/schema-registry-integration-with-logstash-kafka-input-plugin/335431 "2023-06-07T10:41:34Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![Hemanth\_Gowda](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/hemanth_gowda/32/23886_2.png) [@Hemanth\_Gowda](https://discuss.elastic.co/u/Hemanth_Gowda)\
**Post date:** [June 7, 2023, 10:41am UTC](https://discuss.elastic.co/t/schema-registry-integration-with-logstash-kafka-input-plugin/335431/1 "2023-06-07T10:41:34Z")

</div>

Hi All,

We are trying to setup Kafka Schema registry integration with Logstash. However we have below questions to understand before we start with. Can someone please help with this.

1. We have multiple dynamic schemas in schema registry and when ever there is a change in schema, our Logstash pipeline should accommodate this new change in schema and should not break the pipeline. Is it possible to achieve this?

2. Ideally a schema registry can have multiple schema versions associated with. Basically we point to schema\_registry\_url in logstash input plugin. Can we identify what schema version of the schema registry the read message is associated with?

For example: message1 and message2 are consumed from same topic. message1 is using schema1 and message2 is using schema2. Can we identify message1 is using schema1 in Logstash pipeline?  
If yes - How can we identify? Is it part of event message.  
If no - We wanted to know the reason. Because we point to schema\_registry\_url in input plugin.  
Ideally we are not reading one schema but complete schema registry which should contain all the schemas.

---

<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 5, 2023, 10:41am UTC](https://discuss.elastic.co/t/schema-registry-integration-with-logstash-kafka-input-plugin/335431/2 "2023-07-05T10:41:52Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.