In this chapter, we will discuss reactive programming design patterns in Go. Reactive programming is a programming concept that focuses on data streams and the propagation of change. Technologies such as Kafka allow you to quickly produce or consume a stream of data. As a result, these technologies are a natural fit for one another. In the Connecting Kafka to Goflow recipe, we'll explore combining a kafka message queue with goflow to show a practical example of using these technologies. This chapter will also explore various ways to connect with Kafka and use it to process messages. Lastly, this chapter will demonstrate how to create a basic graphql server in Go.

In this chapter, we will cover the following recipes:

• Using Goflow for data flow programming
• Using Kafka with Sarama
• Using async producers with Kafka
• Connecting Kafka to Goflow
• Writing a GraphQL server in Go