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

MySQL SourceInfo should be public

XMLWordPrintable

      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
      //........

       

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

                Created:
                Updated:
                Resolved: