← Back to branch summary

~stub/bottledwater/trunk

« back to all changes in this revision

Viewing changes to kafka/table_mapper.h

  • Committer: GitHub
  • Author(s): Sam Stokes
  • Date: 2016-08-11 17:19:41 UTC
  • mfrom: (128.2.10)
  • Revision ID: git-v1:a69dc9ef900b6f4ec3a483217d71504efe0d1fce
Merge pull request #102 from mcapitanio/master

Include Postgres schema name in Kafka topic name.  Fixes #93.

Show diffs side-by-side

added added

removed removed

Lines of Context:
kafka/table_mapper.h
11
11
#define TABLE_MAPPER_SCHEMA_ID_MISSING (-1)
12
12
#define TABLE_MAPPER_ERROR_LEN 512
13
13
#define TABLE_MAPPER_MAX_TOPIC_LEN (256 + 1)
14
 
#define TABLE_MAPPER_TOPIC_PREFIX_DELIMITER '-'
 
14
#define TABLE_MAPPER_TOPIC_PREFIX_DELIMITER '.'
15
15
 
16
16
 
17
17
typedef struct {