Github user srdo commented on the pull request: https://github.com/apache/storm/pull/1380#issuecomment-216496822 @HeartSaVioR Sure. The current logs look like this "Starting Kafka 10.4.5.1:0 from offset 15520", which doesn't tell you which topic it's affecting. The logs in L259 and L269 don't tell you which partition/topic they're affecting at all. This PR changes the log to use the toString on Partition for logging, which looks like this: "Starting Kafka 10.4.5.3 Partition{host=10.4.5.3:9092, topic=dce-data, partition=26} from offset 1612424"
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---