- I created a subject like this
val subject: Subject = Subject.SubjectBuilder()
Where seeker.subjectId is a string.
This is the client I’m using.
val client = OkHttpClient.Builder()
val adapter: HttpClientAdapter = OkHttpClientAdapter.builder()
where ‘collector’ is my collector’s URL. also string.
This is my emitter
val emitter: Emitter = BatchEmitter.builder()
This is the tracker
val tracker: Tracker = Tracker.TrackerBuilder(emitter, “AF003”, “cf”)
I’m trying to use an Unstructured event with this code
where context is a mapof(field: data) with the schema using the SelfDescribingJson method like this.
val context = SelfDescribingJson(schema, eventMap)
Also I’m not getting anything from the callback logs in the emitter.
I’m using buffersize = 1 just for testing purposes.
Am I missing something? Thank you in advance.