This caused any messages published by CAP with a kafka key set to not be consumable by CAP.

Co-authored-by: Andrew Jaffie <andrewj@avi.com>

* Architectural refactoring

* Add new memory serializer

* code refactor

* Add service inject

* update to publish

* Fix message consumer bugs

* upgrade to netcoreapp3.0

* remove discoverys code

* remove unused files

* Code refactor

* code cleanup

* remove unused file

* upgrade nuget and upgrade framework to netstandard 2.1

* add async support for CAPTransaction

* bug fixed

* Typo: "Getting Stared"

* Add dashboard api interface

* Add Nodediscovry

* remove unused file

* upgrade dashoboard module

* Rename file

* Refactoring postgresql implementation for version 3.0

* Fixed mysql dashboard query bug

* Code refactoring

* Refactoring sqlserver implementation for version 3.0

* Refactoring mongo implementation for version 3.0

* Add index for mysql table

* Fixed sqlserver connection async issue

* Refactoring kafka transport implementation for version 3.0

* Refactoring inmemory storage implementation for version 3.0

* Refactoring azure serverbus transport  implementation for version 3.0

* Update samples to netcoreapp3.0

* Refactoring namespace

* Change System.Text.Json to Json.NET

* Code refactoring

* Rename class

* Fix obsolete

* Fix kafka consumer client bugs

* Fix sql reader  column index error

* Introduced rewrite table name option

* Introduced rewrite table name option

* Introduced rewrite table name option for pgsql

* Introduced rewrite table name option

* Fix SqlServer service injection bug

* Fix sql bug

* Fix Kafka transport check not working bug. #436

* code cleanup

* update samples

* Adjust dashboard display

* Refacing diagnostics tracing module.

* Code cleanup

* Remove outdated unit tests

* Add sync publish method with additional header

* update version to 3.0

* Add fake transport fot unit tests

* Support null value of message body.

* Rename class

* Rename class

* Fix mysql unit tests

* Fix  loops when configuration items are abnormal or unreachable. #444

* Refactoring

* Add sqlsever samples

* Schema renaming to lowercase is more conformant

* Fix SQL Server tranaction error in entityframework. #402

* update readme

* update ci yml

* Remove the database integration test

* fix build error

* upgrade mongo nuget package to 2.10.0, because 2.8.0  have bugs in .net core 3.0

* Fix mongodb dashboard query bugs

* update samples

* Fix postgresql storage bugs

* Fix build error

* Fix unit tests

* Fix build errorFix unit tests

* Add Kafka options to support  custom header to add offset and partition into CapHeader.  #374

* Code refactor

* update code format

* Add options package reference

* Rename need retry processor

* update unit tests

* Improve ICapPublisher to singleton.

* Support options pattern for MySqlOptions

* Support options pattern for PostgreSqlOptions

* Remove reference

* update namespace of SubscriberNotFoundException.cs

* update ut

* Support options pattern for CapOptions

* update version to 2.6.0

* Support options pattern for AzureServiceBusOptions

* Fix client listening bug

* update inmemory project to using  option pattern.

* Support options pattern for KafkaOptions.

* Support options pattern for MongoDbOptions.

* Fix options.

* Support options pattern for SqlServerOptions

* upgrade confluent kafka to 1.1.0

* Remove CastleCoreTest project, it is not need again

* Fix transaction dispose.

* Fix mock

* Fix mock

* Update README.zh-cn.md

* Delete README.2.2.md

* Fix  flush unclaer data bugs.

* Update README.md

* Update README.md

* Update README.zh-cn.md

* update readme.md to add the subscriber group descriptions.

* update readme

* update version to 2.3.1

* add SnowflakeId unit tests

* update build.cake for unit test adjustment

* remove unused config file

* update readme

* update readme

* Fixed dashboard messages requeue error. ( #205 )

* Refactoring

* Fixed SnowflakeId workerId to random id.

* Update README.md

* upgrade dependent nuget packages.

* Add SourceLink Support

* fixed message enqueue exception in v2.2

* add log to samples

* Improved log output.  #114

* add default timeout configuration for kafka client.

* fixed retry processor bugs.

* Fixed kafka producer exception log without logging when publish message.

* update version num to 2.2.2

* rename configuration options FailedCallback to FailedThresholdCallback

* rename files name.

* remove unused files.

* modify the error comments.

* update samples.

* add logs.

* fixed message enqueue exception in v2.2

* add log to samples

* Improved log output.  #114

* add default timeout configuration for kafka client.

* fixed retry processor bugs.

* Fixed kafka producer exception log without logging when publish message.

* update version num to 2.2.2

* rename configuration options FailedCallback to FailedThresholdCallback

* rename files name.

* remove unused files.

* modify the error comments.

* update samples.

* add logs.