Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-3638

MySQL SourceInfo should be public

    XMLWordPrintable

Details

    Description

      I see every SourceInfo is public, except for mysql.

      when i parse SourceRecord in my code,them like this:

      Struct value = (Struct) record.value(); 
String schemaName = ((Struct) value.get(Envelope.FieldName.SOURCE)).getString(CloudEventsMaker.FieldName.SCHEMA_FIELD_NAME);
String serverId = value.getString("server_id"); // hard code 
//........

      actually, i want:

            Struct value = (Struct) record.value();
      String schemaName = ((Struct) value.get(Envelope.FieldName.SOURCE)).getString(CloudEventsMaker.FieldName.SCHEMA_FIELD_NAME);
      String serverId =  value.getString(SourceInfo.SERVER_ID_KEY);  // if  "server_id" will change, i can void upgrade problem
      //........

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            camilesing Camile Sing (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: