Hello, I need a suggestion. I want to enrich one K...
# troubleshooting
n
Hello, I need a suggestion. I want to enrich one Kafka Stream with another and i am not able to decide between KeyedCoProcessFunction or BroadcastProcessFunction. What should i consider while deciding between these two? There will be fault tolerance in both the scenarios. KeyedCoProcessFunction with MapState will also be checkpointed. I am giving the example of my usecase below. Main Kafka Topic schema {"resturantId":"abc", "orderId":"123", "orderValue":500} MY secondary Topic schema {"restaurantId":"abc", "restaurantName":"fancy"} Q. If I use KeyedCoProcessFunction with MapState, there will be multiple instance of MapState containing data corresponding to keyed restaurantId. Will this be taking more resources in terms of memory? Q. There is KeyedBroadcastProcessFunction as well. I dont have any usage of Timer functionality. Isnt Keyed Streams are more expensive in terms of resources? i am avoiding it because of this reason. Please correct me if i am wrong here. The secondary topic data will not exceed more than 100MB. Which one would be better in terms of resources? Thank You.