Mukund Agarwal

@bob9 sadly i couldn't find any way to make it work except hard coding the table format for which i was working

Do I need to update the jar package of kafka connector and kafka confluent ?

@C0urante data looks like this : {u'source': {u'name': u'full', u'lsn': 146716754490, u'last_snapshot_record': None, u'txId': 11059, u'version': u'0.7.5', u'snapshot': None, u'ts_usec': 1530220086573566000}, u'ts_ms': 1530220086599, u'after': {u'b_date': 51927, u'id': 23, u'name': u'dsd'},...

@C0urante I tried SMTs but they are not working ... is there an alternative using the schemaRetriever class modifications ? I want to pass the json of only "after" to...

I would also want to know which class serves as main class if I want to create jar file for each package inside the connectors directory.

@C0urante I added the same SMT as you gave in the properties file but the SMT did not pass only the required field. All fields entered the bigQuery. Which class...