encoder/json.go (4 lines):
	- line 54: /*TODO: Come up with better day of doing this*/
	- line 192: name, _ := time.Now().Zone() //TODO: cache this
	- line 239: //FIXME: to properly handle integer need to use decoder and json.UseNumber
	- line 266: //FIXME: Fix datatypes same as in fields


encoder/avro.go (4 lines):
	- line 96: //TODO: Explore using reader/writer interface
	- line 111: err := rec.Set("row_key", []byte(GetCommonFormatKey(cfEvent))) //TODO: Revisit row_key from primary_key
	- line 298: //TODO: Remove ability to encode schema, so as receiver should have schema to decode
	- line 311: //TODO: Consider passing primary key as fields in delete event, instead


pipe/kafka.go (4 lines):
	- line 187: //TODO: Think about moving offsets handling SQL to state package
	- line 260: // FIXME: Config kafka and handle errors. By default errors logged only and not returned by the channel
	- line 353: //FIXME: Can't use buffered channel here, because in the case, when one of
	- line 447: //FIXME: Avoid linear search below


changelog/mysql.go (3 lines):
	- line 522: //TODO: Produce as a batch
	- line 795: //TODO: Commit only tables which had data in this batch
	- line 845: //TODO: Unify with streamer logic. Extract MaxBatchSize from per table


pipe/file.go (3 lines):
	- line 54: //TODO: Support reading file currently open by producer
	- line 55: //TODO: Support offset persistence
	- line 932: //TODO: Get encryption and compression type from Filters field of the header


util/util.go (3 lines):
	- line 221: /*FIXME: Use sql.ColumnType.DatabaseType instead if this function if go1.8 is
	- line 270: case "uint8", "uint16", "uint32": // FIXME: uint64
	- line 276: default: //FIXME: Date, DateTime, Enum, Array


server/schema_handler.go (2 lines):
	- line 243: //TODO: Validate schema
	- line 274: //FIXME: Do not return actual error


encoder/sql.go (2 lines):
	- line 106: //FIXME: Assumes that cf is in input schema format, so we need to filter it
	- line 296: //FIXME: Encode schema from c instead of sqlEncoder current schema


config/config.go (2 lines):
	- line 146: Interval time.Duration //seconds. TODO: Implement proper duration unmarshalling
	- line 252: //TODO: implement cmdline and env loaders


schema/mysql_avro_schema_converter.go (2 lines):
	- line 54: //TODO: Confirm correct Avro type for BINARY/VARBINARY types
	- line 76: //TODO: Add geometry types


schema/table_schema.go (2 lines):
	- line 47: /*FIXME: Can I pass nil here? */
	- line 57: )`) //FIXME: Is there a better way to insert \n


schema/alter_schema.go (1 line):
	- line 38: //TODO: Wrap below SQL calls in a transaction


state/manager.go (1 line):
	- line 482: //TODO: Deduplicate with SyncRegisteredTables


pipe/local.go (1 line):
	- line 118: //TODO: Drain the channel here


log/zap.go (1 line):
	- line 66: //FIXME: Need to set zap.AddCallerSkip(0) to show correct line numbers for non


state/clusters.go (1 line):
	- line 84: //FIXME: Add connection type to info in state


encoder/encoder.go (1 line):
	- line 100: //TODO: Should we encode into byte array instead?


lock/lock.go (1 line):
	- line 62: //TODO: Improve performance of sharded lock. Now we linearly try to take the


metrics/metrics.go (1 line):
	- line 50: //TODO: ERRORS


pipe/cache.go (1 line):
	- line 48: //FIXME: Implement proper collisions handling


pipe/sql.go (1 line):
	- line 371: //TODO: implement


db/open.go (1 line):
	- line 66: //FIXME: in go1.8 change to: err = dbc.PingContext(shutdown.Context)


config/mysql.go (1 line):
	- line 171: //TODO: Prevent overwriting newer config in DB, by comparing updatedAt variable and


state/schema.go (1 line):
	- line 93: //TODO: Implement proper schema version handling in state


server/table_handler.go (1 line):
	- line 121: //TODO: Implement generic interface for handing offsets in pipe


log/log.go (1 line):
	- line 148: //FIXME: this prints file/line of the l.Errorf call not EL caller


streamer/buffer.go (1 line):
	- line 112: // FIXME: We currently support only raw messages from local pipe or CommonFormat messages