Ask Your Question

Revision history [back]

click to hide/show revision 1
initial version

MapR DB CDC Consumer

I'm trying the use of the MapR DB CDC Consumer. I had created a MapR DB JSON with CDC enabled and attached to a MapR Stream. I can see the change logs on the stream using mapr streamanalyzer. However, the CDC consumer isn't getting anything.

 mapr streamanalyzer -path /store_db/bintest/people_changelog -topics people -printMessages true
 ID: p000tpeople:00000001000000000000000060:0 topic: people partition: 0 offset: 0 producer: mapr key: <binary> value: <binary>
 ID: p000tpeople:00000001000000000000000060:1 topic: people partition: 0 offset: 1 producer: mapr key: <binary> value: <binary>
 ID: p000tpeople:00000001000000000000000060:2 topic: people partition: 0 offset: 2 producer: mapr key: <binary> value: <binary>
 ID: p000tpeople:00000001000000000000000060:3 topic: people partition: 0 offset: 3 producer: mapr key: <binary> value: <binary>
 ID: p000tpeople:00000001000000000000000060:4 topic: people partition: 0 offset: 4 producer: mapr key: <binary> value: <binary>
 ID: p000tpeople:00000001000000000000000060:5 topic: people partition: 0 offset: 5 producer: mapr key: <binary> value: <binary>
Total number of messages: 6

In the MapR DB CDC tab, I filled out the following:

  • Topic List (left box) = /store_db/bintest/people_changelog:people
  • Topic List (right box) = /store_db/bintest/people (the MapR DB table that generated the change log)

As reference, I ran the following commands to setup the table, streams and their association.

maprcli table create -path /store_db/bintest/people -tabletype json
maprcli stream create -path /store_db/bintest/people_changelog -ischangelog true -consumeperm 'u:sdc'
maprcli table changelog add -path /store_db/bintest/people -changelog /store_db/bintest/people_changelog:people

Any ideas/tips I can look into to make this work?

Thanks