# Kafka **URL:** https://discuss.aerospike.com/c/connectors/kafka/208.md [Latest](https://discuss.aerospike.com/latest.md) · [Categories](https://discuss.aerospike.com/categories.md) · [Tags](https://discuss.aerospike.com/tags.md) --- ## [About the Kafka category](https://discuss.aerospike.com/t/about-the-kafka-category/6450)
**Author:** [@kporter](https://discuss.aerospike.com/u/kporter)\ **Replies:** 0
Section to discuss Aerospike’s Kafka Connector. --- ## [Kafka Outbound Connector - using map data type with Kafka Avro format](https://discuss.aerospike.com/t/kafka-outbound-connector-using-map-data-type-with-kafka-avro-format/9931)
**Author:** [@savsr](https://discuss.aerospike.com/u/savsr)\ **Replies:** 2\ **Last updated:** [January 6, 2023, 6:50pm UTC](https://discuss.aerospike.com/t/kafka-outbound-connector-using-map-data-type-with-kafka-avro-format/9931 "2023-01-06T18:50:39Z")
Hi. Am trying to setup data in Kafka Outbound connector with Aerospike. When trying to use Kafka Avro format for messages, I noticed the following error: aerospike-kafka\_connector-1 | 2022-12-22 20:27:17.607 GMT INFO … --- ## [Kafka source connector with aerospike](https://discuss.aerospike.com/t/kafka-source-connector-with-aerospike/8708)
**Author:** [@shubhamdangare](https://discuss.aerospike.com/u/shubhamdangare)\ **Replies:** 3\ **Last updated:** [August 12, 2021, 11:42pm UTC](https://discuss.aerospike.com/t/kafka-source-connector-with-aerospike/8708 "2021-08-12T23:42:51Z")
i have setup aerospike with all the configuration required for kafka and m using confluent local cluster for kafka and have installed Aerospike Source Connector | Confluent Hub and have started confluent cluster but stil… --- ## [Resetting AerospikeSinkConnector offsets](https://discuss.aerospike.com/t/resetting-aerospikesinkconnector-offsets/8719)
**Author:** [@Zvi\_Mints](https://discuss.aerospike.com/u/Zvi_Mints)\ **Replies:** 0\ **Last updated:** [August 11, 2021, 8:09pm UTC](https://discuss.aerospike.com/t/resetting-aerospikesinkconnector-offsets/8719 "2021-08-11T20:09:44Z")
Hey, I’m trying to reset offsets for a specific connect named x , for that i’m resetting the group.id connector-x , I indeed see that all the offsets are 0, but when I redeploy the connector I see that all of the offsets… --- ## [What can i do if both write and read operations are in the same Kafka topic](https://discuss.aerospike.com/t/what-can-i-do-if-both-write-and-read-operations-are-in-the-same-kafka-topic/7814)
**Author:** [@Ariel\_Roasso](https://discuss.aerospike.com/u/Ariel_Roasso)\ **Replies:** 3\ **Last updated:** [September 15, 2020, 10:51pm UTC](https://discuss.aerospike.com/t/what-can-i-do-if-both-write-and-read-operations-are-in-the-same-kafka-topic/7814 "2020-09-15T22:51:17Z")
Is it possible to dynamically set operation type? https://www.aerospike.com/docs/connectors/enterprise/kafka/inbound/configuration/topics.html#aerospike-operation-config --- ## [Aerospike connector sink errors.tollerance=all is not working](https://discuss.aerospike.com/t/aerospike-connector-sink-errors-tollerance-all-is-not-working/7163)
**Author:** [@sgodzevych](https://discuss.aerospike.com/u/sgodzevych)\ **Replies:** 0\ **Last updated:** [February 24, 2020, 9:56am UTC](https://discuss.aerospike.com/t/aerospike-connector-sink-errors-tollerance-all-is-not-working/7163 "2020-02-24T09:56:22Z")
Hi, I’m using aerospike-connector-sink 0.0.4 and use policy.record\_exists\_action=create\_only locally and set errors.tollerance=all but connector stops when key already exists error - as I see - errors tollerance is not w… --- ## [Using aerospike-kafka connector in a distributed environment](https://discuss.aerospike.com/t/using-aerospike-kafka-connector-in-a-distributed-environment/6732)
**Author:** [@Mich\_Talebzadeh](https://discuss.aerospike.com/u/Mich_Talebzadeh)\ **Replies:** 0\ **Last updated:** [October 15, 2019, 6:59pm UTC](https://discuss.aerospike.com/t/using-aerospike-kafka-connector-in-a-distributed-environment/6732 "2019-10-15T18:59:37Z")
Assuming that you have a Kafka cluster with 9 brokers and replication factor of 9 for failover: \*\*${KAFKA\_HOME}/bin/kafka-topics.sh --describe --zookeeper rhes75:2181, rhes564:2181, rhes76:2181 --topic md\*\* Topic:md … --- ## [Aerospike Kafka connector throwing error max connections 25 would be exceeded](https://discuss.aerospike.com/t/aerospike-kafka-connector-throwing-error-max-connections-25-would-be-exceeded/6446)
**Author:** [@Mich\_Talebzadeh](https://discuss.aerospike.com/u/Mich_Talebzadeh)\ **Replies:** 3\ **Last updated:** [July 10, 2019, 7:50am UTC](https://discuss.aerospike.com/t/aerospike-kafka-connector-throwing-error-max-connections-25-would-be-exceeded/6446 "2019-07-10T07:50:55Z")
Hi, Aerospike connect to Kafka from time to time throwing the following error when running in standalone mode as below $KAFKA\_HOME/bin/connect-standalone.sh etc/connect-standalone.properties etc/aerospike-sink.properti…