Feature: dynamic target topic routing

[gwaramadze]

• Enhanced StreamingDataFrame.to_topic() to accept a callable that returns a Topic object based on message content (value, key, timestamp, headers).
• Enables dynamic message routing to different topics based on message content.
• Maintains backward compatibility with existing Topic object usage
• Includes performance guidance to prevent accidental topic proliferation