diff --git a/esphome/components/canbus/canbus.h b/esphome/components/canbus/canbus.h
index a78d6d8230..49230ab95b 100644
--- a/esphome/components/canbus/canbus.h
+++ b/esphome/components/canbus/canbus.h
@@ -96,29 +96,20 @@ class Canbus : public Component {
   virtual ERROR set_bitrate_(const CAN_SPEED canSpeed);
 };
 
-class MQTTMessageTrigger : public Trigger<std::string>, public Component {
+class CanbusTrigger : public Trigger<int>, public Component {
  public:
-  explicit MQTTMessageTrigger(const std::string &topic);
+  explicit CanbusTrigger(const int &can_id);
 
-  void set_qos(uint8_t qos);
   void set_payload(const std::string &payload);
   void setup() override;
   void dump_config() override;
   float get_setup_priority() const override;
 
  protected:
-  std::string topic_;
-  uint8_t qos_{0};
+  std::string can_id_;
   optional<std::string> payload_;
 };
 
-class MQTTJsonMessageTrigger : public Trigger<const JsonObject &> {
- public:
-  explicit MQTTJsonMessageTrigger(const std::string &topic, uint8_t qos) {
-    global_mqtt_client->subscribe_json(
-        topic, [this](const std::string &topic, JsonObject &root) { this->trigger(root); }, qos);
-  }
-};
 
 }  // namespace canbus
 }  // namespace esphome
\ No newline at end of file