ืืื ืืืืจ!
ืืื ืึทืจืืขื ืืืืฃ ืื ืืื ืงืึธืคืฃ ืืึทื ืฉืึทืคึฟื, ืืืึธืก ืืื ืืขืืืขืืึธืคึผืื ื ืืืื ืืืืืขื ืข ืึธื ืืึธื ืฆืขื ืืขืจ. ืืื ืืขืจืกืื ืก ืึทื ืืืืืงืืขื ืืื ืืืฉืึทืืืึท ื ืืฆื ืกืคึผืจืื ื ืฉืืืืื ืืื ืกืึธืืืืข ืคืึทืจืฉืืื ืืขืื ืืฉ ืคึผืจืึธืืืขืืก ืืืึธืก ืฉืืืืขื ืืื ืึท ืคึผืจืืืขืงื.
ืจืืึฟ ืคืื ืืื ืืืขืจ ืืืงืจืึธืกืขืจืืืืกืขืก ืืืขืจืืขืื ืืื ืืขืืขืจ ืื ืืขืจืข ืืืกืื ืืงืจืึทื ืึทืกืื ืืืจื ืึท ืึธื ืืึธื ืืขืงืืขืจ. ืืื ืึทืืขืจ, ืืืจ ืืขืืืืื ื IBM MQ ืืื ืึท ืืขืงืืขืจ, ืืืึธืก ืงืขื ื ืื ืืขืจ ืงืึธืคึผืข ืืื ืื ืืึทืกืข, ืึธืืขืจ ืืื ืืขืจ ืืขืืืืงืขืจ ืฆืืึทื ืืื ืืืื ืขืงืกืคึผืจืขืก ืืขืจืึทื ืืื.
ืืื ืึท ืคืึทืจืืืึทื, ืืืจ ืืขื ืขื ืืขืคึฟืื ื Apache Kafka, ืืืึธืก ืืื ืึท ืืืื ืกืงืืืืื ื ืคึผืึธืืขื ืฆืืขื, ืึธืืขืจ, ืืืืืขืจ, ืจืืงืืืืืขืจื ืึท ืึผืืขื ืืืื ืฆืืืึทื ื ืฆื ืงืึทื ืคืืืืขืจืืืฉืึทื ืคึฟืึทืจ ืคืึทืจืฉืืืขื ืข ืกืื ืขืจืืึธืื. ืืื ืึทืืืฉืึทื, ืื ืขืงืกืคึผืจืขืก ืืขืงืึทื ืืืึทื ืืื ืืื ืืกืืขืจ ืึทืืึธื ืืืึธืก ืึทืจืืขื ืืื Kafka ืืืจื ืคืขืืืงืืึทื ืืื ื ืืฉื ืืึธืื ืื ืคืืจืืื ืื ืงืึธื ืกืืกืืขื ืกื ืืืจืื ืคืื ืื ืงืขืกืื. ืืขืจื ืึธื, ืืื ืืืขื ืืืืื ืืื ืืืขืจ ืืขืจืคืึทืจืื ื ืืื ืงืึทืคืงืึท ืงืึทื ืคืืืืขืจืืืฉืึทื, ืืื ืืึทืืื ืืขืจ, ืืื ืืืขื ืืึธืื ืืืจ ืืื ืฆื ืงืึทื ืคืืืืขืจ ืืื ืืขืื ืืื ืคึผืื ืงื ืึทืืึธื ืขืงืกืคึผืจืขืก.
ืืขืจืึทื ืืื ืขืงืกืคึผืจืขืก ืืื ืืขืจ
ืื ืกืขืืืื ืืก ืืืกืงืึทืกื ืืื ืื ืืืขื ืืขืืคื ืคืึทืจืืืึทืื ืึท ื ืืืขืจ ืคืื ืคึผืจืึธืืืขืืก ืืื ืื ืคืขืืืงืืึทื ืคึฟืึทืจืืื ืืื ื ืกืขืืืื ืืก. ืืืขืจ ืขืจืฉืืขืจ ืืื ืืืึธืื ืืื ืฆื ืืึทืฆืึธืื ืืคืืขืจืงืืึทืืงืืึทื ืฆื ืืืื ืคึผืึทืจืึทืืขืืขืจ ืืืึธืก ืืืขื ืคืึทืกืืืึทืืืื ืึท ืืขืืืขื ืืืืึทื.
ืืืก ืืืขื ืืขืืคื client.id ืคึฟืึทืจ ืคึผืจืึธืืืฆืืจืขืจ ืืื ืงืึธื ืกืืืขืจ. ืืื ืขืจืฉืืขืจ ืืืืง, ืืืจ ืงืขื ืขื ื ืืฆื ืื ืึทืคึผืืึทืงืืืฉืึทื ื ืึธืืขื ืืื ืื ืืืขืจื, ืืื ืืื ืจืืึฟ ืงืึทืกืขืก ืืึธืก ืืืขื ืึทืจืืขืื. ืืึธืืฉ ืื ืกืืืืึทืฆืืข ืืืขื ืึท ืึทืคึผืืึทืงืืืฉืึทื ื ืืฆื ืขืืืขืืข ืงืึธื ืกืืืขืจืก ืืื ืืืจ ืืขืื ืืื ืื ืืขืืืข client.id, ืจืขืืืืืึทืื ืืื ืื ืคืืืืขื ืืข ืืืืจืขื ืื ื:
org.apache.kafka.common.utils.AppInfoParser โ Error registering AppInfo mbean javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=kafka.test-0ืืืื ืืืจ ืืืืื ืฆื ื ืืฆื JMX ืืื ืึท ืึทืคึผืืึทืงืืืฉืึทื ืืื Kafka, ืืึธืก ืงืขื ืืืื ืึท ืคึผืจืึธืืืขื. ืคึฟืึทืจ ืืขื ืคืึทื, ืขืก ืืื ืืขืกืืขืจ ืฆื ื ืืฆื ืึท ืงืึธืืืื ืึทืฆืืข ืคืื โโโโืื ืึทืคึผืืึทืงืืืฉืึทื ื ืึธืืขื ืืื, ืคึฟืึทืจ ืืืึทืฉืคึผืื, ืื ืืขืืข ื ืึธืืขื ืืื ืื client.id ืืืขืจื. ืืขืจ ืจืขืืืืืึทื ืคืื ืืื ืืืขืจ ืงืึทื ืคืืืืขืจืืืฉืึทื ืงืขื ืขื ืืืื ืืขืืขื ืืื ืื ืืึทืคึฟืขื ืจืขืืืืืึทื ืงืึทืคืงืึท-ืงืึทื ืกืืืขืจ-ืืจืืคึผืขืก ืคืื ืืืืืืึทืืื ืคืื ืงืึธื ืคืืืขื ื:
ืืืฆื ืืึธืื ืก ืงืืง ืืื ืื ืกืฆืขื ืึทืจ ืคึฟืึทืจ ืืขืจืึทื ืืื ืึธื ืืึธื ืขืงืกืคึผืจืขืก. Kafka ืคึผืจืึธืืืฆืืจืขืจ ืืื ืึท ืคึผืึทืจืึทืืขืืขืจ ืึทืงืก, ืืืึธืก ืึทืืึทืื ืืืจ ืฆื ืงืึทื ืคืืืืขืจ ื ืึธื ืืื ืคืืืข ืืงื ืึทืืืืืฉื ืืขืจ ืงื ืืื ืคืืจืขืจ ืืึทืจืฃ ืฆื ืืึทืืจืึทืืื ืื ืึธื ืืึธื ืืฆืืื ืืขืฉืจืืื. ืืขืจ ืคึผืึทืจืึทืืขืืขืจ ืงืขื ื ืขืืขื ืื ืคืืืืขื ืืข ืืืึทืืืขืก:
- 0 - ืืึทืฉืืขืืืงื ืืืขื ื ืื ืืืื ืืึทืืจืึทืื.
- 1 ืืื ืื ืคืขืืืงืืึทื ืคึผืึทืจืึทืืขืืขืจ, ืืืืื 1 ืจืขืคึผืืืงืข ืืื ืคืืจืืื ืื ืฆื ืืึทืฉืืขืืืงื.
- -1 - ืืึทืฉืืขืืืงื ืคืื ืึทืืข ืกืื ืืงืจืึทื ืืืื ืจืขืคึผืืึทืงืึทื ืืื ืคืืจืืื ืื (ืงื ืืื ืกืขืืึทืคึผ min.insync.replicas).
ืคึฟืื ืื ืืืกืืขื ืืืึทืืืขืก ืขืก ืืื ืงืืึธืจ ืึทื ืึทืงืก ืืืืึทื ืฆื -1 ืืื ืื ืกืืจืึธื ืืขืกื ืืึทืจืึทื ืืืจื ืึทื ืืขืจ ืึธื ืืึธื ืืืขื ื ืืฉื ืืืื ืคืึทืจืคืึทืื.
ืืื ืืืจ ืึทืืข ืืืืกื, ืืืกืืจืืืืืืื ืกืืกืืขืืขื ืืขื ืขื ืึทื ืจืืืืืึทืืึทื. ืฆื ืืึทืฉืืฆื ืงืขืื ืืจืึทื ืืฉืึทื ื ืืกืจืื ืืช, Kafka ืคึผืจืึธืืืกืขืจ ืืื ืื ืึธืคึผืฆืืข ืจืืืจืืขืก, ืืืึธืก ืึทืืึทืื ืืืจ ืฆื ืฉืืขืื ืื ื ืืืขืจ ืคืื ืจืขืกืขื ื ืคืจืืืื ืื ืขืงืกืคึผืจืขืก.ืืืืขืึธืื.ืืก. ืืื ื ืื ืจืขืืจืืขืก ืคึผืึทืจืึทืืขืืขืจ ืืื ืึท ืคืขืืืงืืึทื ืืืขืจื ืคืื Integer.MAX_VALUE (2147483647), ืื ื ืืืขืจ ืคืื ืึธื ืืึธื ืจืืืจืืขืก ืงืขื ืขื ืืืื ืึทืืืฉืึทืกืืื ืืืจื ืืฉืึทื ืืื ื ืืืืื ืืขืืืืืขืจื.ืืืืขืึธืื.ืืก.
ืืืจ ืืขื ืขื ืืึธืืืื ื ืฆื ืคึผืื ืงื ืึทืืึธื ืขืงืกืคึผืจืขืก
ืื ืืืกืืขื ืกืขืืืื ืืก ืืึธืื ืืื ืืืขืจ ืคึผืจืึธืืืฆืืจืขืจ ืฆื ืืึทืคืจืืึทืขื ืึทืจืืืงืืขื ืืื ืึท ืืืื ืืึทืจืึทื ืืืจื. ืืื ืก ืืืฆื ืจืขืื ืืืขืื ืืื ืฆื ืขื ืฉืืจ ืึทื ืืืืื ืืืื ืงืึธืคึผืืข ืคืื โโืึท ืึธื ืืึธื ืืื ืืขืฉืจืืื ืฆื ืึท ืงืึทืคืงืึท ืืขืืข? ืืื ืื ืกืืืคึผืืึทืกื ืคืึทื, ืฆื ืืึธื ืืึธืก, ืืืจ ืืึทืจืคึฟื ืฆื ืฉืืขืื ืืขื ืคึผืึทืจืึทืืขืืขืจ ืืืืฃ ืคึผืจืึธืืืกืขืจ ืืขืื.ืืืขืืคึผืึธืืขื ืกืข ืฆื ืืืช. ืืืืขืืคึผืึธืืขื ืกื ืืขืจืึทื ืืื ืึทื ืืืืื ืืืื ืึธื ืืึธื ืืื ืืขืฉืจืืื ืฆื ืึท ืกืคึผืขืฆืืคืืฉ ืฆืขืืืืืื ื ืคืื ืืืื ืืขืืข. ืื ืคึผืจืืืืกืคึผืึทืืืฉืึทื ืคึฟืึทืจ ืื ืืืืึทืืื ื ืืืืขืืคึผืึธืืขื ืกื ืืื ืื ืืืึทืืืขืก ืึทืงืงืก = ืึทืืข, ืคึผืจืืืืจื ืืืืืขืจ > 0, max.in.flight.requests.per.connection โค 5. ืืืื ืื ืคึผืึทืจืึทืืขืืขืจืก ืืขื ืขื ื ืืฉื ืกืคึผืขืกืืคืืขื ืืืจื ืื ืืขืืืขืืึธืคึผืขืจ, ืื ืืืืื ืืืึทืืืขืก ืืืขื ืืืื ืืืืืึธืืึทืืืฉ ืืึทืฉืืืื.
ืืืขื ืืืืขืืคึผืึธืืขื ืกื ืืื ืงืึทื ืคืืืืขืจื, ืขืก ืืื ื ืืืืืง ืฆื ืขื ืฉืืจ ืึทื ืื ืืขืืืข ืึทืจืืืงืืขื ืกืืฃ ืึทืจืืืฃ ืืื ืืขืจ ืืขืืืืงืขืจ ืคึผืึทืจืืืฉืึทื ื ืืขืืขืจ ืืึธื. ืืขื ืงืขื ืขื ืืืขืจื ืืขืืื ืืืจื ืืึทืฉืืขืืืงื ืื ืคึผืึทืจืืืึธื ืขืจ.ืงืืึทืก ืฉืืืกื ืืื ืคึผืึทืจืึทืืขืืขืจ ืฆื ืคึผืจืึธืืืกืขืจ. ืืื ืก ืึธื ืืืืื ืืื ืื ืฉืืืกื. ืขืก ืืืื ืืืื ืื ืืขืืืข ืคึฟืึทืจ ืืขืืขืจ ืกืึทืืืืฉืึทื. ืืึธืก ืงืขื ืขื ืืืืื ืืืื ืึทืืฉืืืื ืืืจื ื ืืฆื ืงืืื ืคืื ืื ืืขืฉืขืคื ืืืก ืคืื ืืขืจ ืึธืจืืืื ืขื ืคึผืึธืกืื. ืืขืจ ืคึผืึทืจืึทืืขืืขืจ partitioner.class ืืื ืึท ืคืขืืืงืืึทื ืืืขืจื - . ืืื ืืขื ืคึผืึทืจืืืฉืึทื ืื ื ืกืืจืึทืืขืืืข, ืืืจ ืืึธื ืืื ืืึธืก:
- ืืืื ืื ืฆืขืืืืืื ื ืืื ืืคืืจืืฉ ืกืคึผืขืกืืคืืขื ืืืขื ืฉืืงื ืืขื ืึธื ืืึธื, ืืืจ ื ืืฆื ืขืก.
- ืืืื ืื ืฆืขืืืืืื ื ืืื ื ืืฉื ืกืคึผืขืกืืคืืขื, ืึธืืขืจ ืืขืจ ืฉืืืกื ืืื ืกืคึผืขืกืืคืืขื, ืกืขืืขืงืืืจื ืืขื ืฆืขืืืืืื ื ืืืจื ืื ืืึทืฉ ืคืื ืื ืฉืืืกื.
- ืืืื ืื ืฆืขืืืืืื ื ืืื ืฉืืืกื ืืขื ืขื ื ืืฉื ืกืคึผืขืกืืคืืขื, ืืืืกืงืืืึทืื ืื ืคึผืึทืจืืืฉืึทื ื ืืืื ืขืจ ืืืจื ืืืื ืขืจ (ืงืืึทืืขืืืง ืจืึธืืื).
ืืืื, ื ืืฆื ืึท ืฉืืืกื ืืื ืืืืขืืคึผืึธืืขื ื ืฉืืงื ืืื ืึท ืคึผืึทืจืึทืืขืืขืจ max.in.flight.requests.per.connection = 1 ืืื ืืืจ ืกืืจืืืืืื ื ืึธื ืืึธื ืคึผืจืึทืกืขืกืื ื ืืืืฃ ืื ืงืึธื ืกืืืขืจ. ืขืก ืืื ืืืื ืืืขืจื ืฆื ืืขืืขื ืงืขื ืึทื ืืืื ืึทืงืกืขืก ืงืึธื ืืจืึธื ืืื ืงืึทื ืคืืืืขืจื ืืืืฃ ืืืื ืงื ืืื, ืืืจ ืืืขื ืืึทืจืคึฟื ืจืขืื ืฆื ืืืืขืืคึผืึทืืึทื ืืื ืฉืจืืึทืื ืฆื ืึท ืืขืืข.
ืืืื ืืืจ ืคึผืืืฆืืื ื ืคืขืื ืื ืงืืืคึผืึทืืืืึทืืื ืคืื ืืืืขืืคึผืึทืืึทื ื ืฉืืงื ืืืจื ืฉืืืกื ืึธืืขืจ ืื ืืึธืืืง ืืืืฃ ืื ืคึผืจืึธืืืฆืืจืขืจ ืืืึทื ืจืืงืืืืืจื ืืืื ืืืื ืื ื ืืึทืื ืงืึธื ืกืืกืืขื ืกื ืฆืืืืฉื ืคืึทืจืฉืืืขื ืข ืคึผืึทืจืืืฉืึทื ื, ืืจืึทื ืืึทืงืฉืึทื ื ืืืขื ืงืืืขื ืฆื ืจืึทืืขืืืขื. ืืื ืืขืจืฆื, ื ืืฆื ืึท ืงืืื ืืจืึทื ืกืึทืงืืืึธื, ืืืจ ืงืขื ืขื ืงืึทื ืืืฉืึทื ืึทืื ืกืื ืืงืจืึทื ืืื ืึท ืจืขืงืึธืจื ืืื ืงืึทืคืงืึท, ืืืฉื, ืืื ืึท ืจืขืงืึธืจื ืืื ืื ืืึทืืึทืืืืก. ืฆื ืืขืื ืืจืึทื ืกืึทืงืืืึธื ืึทื ืฉืืงื ืฆื ืื ืคึผืจืึธืืืฆืืจืขืจ, ืขืก ืืืื ืืืื ืืืืขืืคึผืึทืืึทื ื ืืื ืึทืืืฉื ืึทืื ืฉืืขืื ืืจืึทื ืกืึทืงืืืึธื ืึทื.ืื. ืืืื ืืืื ืงืึทืคืงืึท ืงื ืืื ืืื ืึทืงืกืขืก ืงืึธื ืืจืึธื ืงืึทื ืคืืืืขืจื, ืึท ืืจืึทื ืกืึทืงืืืึธื ืึทื ืจืขืงืึธืจื, ืืื ืึท ืืืืขืืคึผืึธืืขื ื ืจืขืงืึธืจื, ืืืขื ืืึทืจืคึฟื ืฉืจืืึทืื ืคึผืขืจืืืฉืึทื ื, ืืืึธืก ืงืขื ืขื ืืืื ืืขืจืืืืื ืืืจื ืืึทืกืงืข ื ืืฆื ืื ืืืขืจื ืกืืึธืจื ืืื transactional.id.
ืคืึธืจืืึทืื, ืงืืื ืฉืืจืืงื, ืึทืืึท ืืื ืื ืึทืคึผืืึทืงืืืฉืึทื ื ืึธืืขื, ืงืขื ืขื ืืืขืจื ืืขื ืืฆื ืืื ืึท ืืจืึทื ืกืึทืงืืืึธื ืืืขื ืืืคืืขืจ. ืึธืืขืจ ืืืื ืืืจ ืงืึทืืขืจ ืขืืืขืืข ืื ืกืืึทื ืกืื ืคืื ืืขืจ ืืขืืืืงืขืจ ืึทืคึผืืึทืงืืืฉืึทื ืืื ืืขืจ ืืขืืืืงืขืจ transactional.id, ืืขืจ ืขืจืฉืืขืจ ืืึธื ืืฉื ืืืึทืฉืคึผืื ืืืขื ืืืื ืกืืึทืคึผื ืืื ืึท ืืขืืช, ืืืืึทื Kafka ืืืขื ืืึทืืจืึทืืื ืขืก ืืื ืึท ืืึทืืื ืคึผืจืึธืฆืขืก.
org.apache.kafka.common.errors.ProducerFencedException: Producer attempted an operation with an old epoch. Either there is a newer producer with the same transactionalId, or the producer's transaction has been expired by the broker.ืฆื ืกืึธืืืืข ืืขื ืคึผืจืึธืืืขื, ืืืจ ืืืืื ืึท ืกืึทืคืืงืก ืฆื ืื ืึทืคึผืืึทืงืืืฉืึทื ื ืึธืืขื ืืื ืื ืคืึธืจืขื ืคืื ืื ืืึธืกืื ืึทืืข, ืืืึธืก ืืืจ ืืึทืงืืืขื ืคึฟืื ืกืืืืืืข ืืืขืจืืึทืืึทืื.
ืืขืจ ืคึผืจืึธืืืฆืืจืขืจ ืืื ืงืึทื ืคืืืืขืจื, ืึธืืขืจ ืืจืึทื ืืึทืงืฉืึทื ื ืืืืฃ Kafka ืงืึธื ืืจืึธืืืจื ืืืืื ืื ืคืึทืจื ืขื ืคืื ืืขื ืึธื ืืึธื. ืจืขืืึทืจืืืขืกืก ืคืื ืื ืืจืึทื ืกืึทืงืืืึธื ืกืืึทืืืก, ืืขืจ ืึธื ืืึธื ืืื ืืืื ืฆื ืื ืืขืืข, ืึธืืขืจ ืืื ื ืึธื ืกืืกืืขื ืึทืืจืืืืืฅ.
ืฆื ืคืึทืจืืืึทืื ืึทืืึท ืึทืจืืืงืืขื ืฆื ืืืืขื ืขื ืืืจื ืื ืงืึธื ืกืืืขืจ ืคืจืืขืจ, ืขืก ืืึทืจืฃ ืฆื ืฉืืขืื ืืขื ืคึผืึทืจืึทืืขืืขืจ isolation.level ืฆื ืืืืขื ืขื_ืงืึทืืืืืืขื ืืืขืจื. ืึทืืึท ืึท ืงืึธื ืกืืืขืจ ืืืขื ืงืขื ืขื ืฆื ืืืืขื ืขื ื ืื-ืืจืึทื ืืึทืงืฉืึทื ืึทื ืึทืจืืืงืืขื ืืื ืคืจืืขืจ, ืืื ืืจืึทื ืกืึทืงืืืึธื ืึทื ืึทืจืืืงืืขื ืืืืื ื ืึธื ืึท ืืืขืจืืขืื.
ืืืื ืืืจ ืืึธื ืืึทืฉืืืื ืึทืืข ืื ืกืขืืืื ืืก ืืืกืืขื ืคืจืืขืจ, ืืืจ ืืึธื ืงืึทื ืคืืืืขืจื ืคึผืื ืงื ืึทืืึธื ืขืงืกืคึผืจืขืก. ืืึทืื - ืืึธืื!
ืืืขืจ ืขืก ืืื ื ืึธื ืืืื ื ืืึทื ืก. Transactional.id, ืืืึธืก ืืืจ ืงืึทื ืคืืืืขืจื ืืืืื, ืืื ืคืืงืืืฉ ืื ืืจืึทื ืกืึทืงืืืึธื ืคึผืจืขืคืืงืก. ืืืืฃ ืื ืืจืึทื ืกืึทืงืืืึธื ืคืึทืจืืืึทืืืขืจ, ืึท ืกืืงืืืึทื ืก ื ืืืขืจ ืืื ืืืกืืฃ ืฆื ืขืก. ืืขืจ ืืืงืืืขื ืืืืขื ืืืคืืืจ ืืื ืืจืืืก ืฆื transactional.id.expiration.ms, ืืืึธืก ืืื ืงืึทื ืคืืืืขืจื ืืืืฃ ืึท ืงืึทืคืงืึท ืงื ืืื ืืื ืืื ืึท ืคืขืืืงืืึทื ืืืขืจื ืคืื "7 ืืขื". ืืืื ืืื ืืขื ืฆืืื ืื ืึทืคึผืืึทืงืืืฉืึทื ืืื ื ืืฉื ืืืงืืืขื ืงืืื ืึทืจืืืงืืขื, ืืืขื ืืืจ ืคึผืจืืืืจื ืื ืืืืึทืืขืจ ืืจืึทื ืกืึทืงืืืึธื ืึทื ืฉืืงื ืืืจ ืืืขื ืืึทืงืืืขื InvalidPidMappingException. ืืขืจ ืืจืึทื ืกืึทืงืืืึธื ืงืึธืึธืจืืื ืึทืืึธืจ ืืืขื ืืขืืึธืื ืึทืจืืืกืืขืื ืึท ื ืืึท ืกืืงืืืึทื ืก ื ืืืขืจ ืคึฟืึทืจ ืืขืจ ืืืืึทืืขืจ ืืจืึทื ืกืึทืงืืืึธื. ืึธืืขืจ, ืืขืจ ืึธื ืืึธื ืงืขื ืืืื ืคืึทืจืคืึทืื ืืืื ืื InvalidPidMappingException ืืื ื ืืฉื ืืึทื ืืึทืื ืจืืืืืง.
ืึทื ืฉืืึธื ืืึธืืืึทืื
ืืื ืืืจ ืงืขื ืขื ืืขื, ืขืก ืืื ื ืืฉื ืืขื ืื ืฆื ื ืึธืจ ืฉืืงื ืึทืจืืืงืืขื ืฆื Kafka. ืืืจ ืืึทืจืคึฟื ืฆื ืงืืืึทืื ืึท ืงืึธืืืื ืึทืฆืืข ืคืื โโืคึผืึทืจืึทืืขืืขืจืก ืืื ืืืื ืฆืืืขืืจืืื ืฆื ืืึทืื ืฉื ืขื ืขื ืืขืจืื ืืขื. ืืื ืืขื ืึทืจืืืงื, ืืื ืืขืคืจืืืื ืฆื ืืืืึทืื ืืื ืืขืืึทื ืื ืคึผืื ืงื ืึทืืึธื ืขืงืกืคึผืจืขืก ืกืขืืึทืคึผ ืืื ืืืกืงืจืืืื ืขืืืขืืข ืคืจืืืืขืืขื ืืื ืื client.id ืืื transactional.id ืงืึทื ืคืืืืขืจืืืฉืึทื ื ืืืึธืก ืืืจ ืืขืคึผืืึธื ืืขืจื. ืื ืืขืจ ืืื ืึท ืงืืฆืขืจ ืคืื ืื ืคึผืจืึธืืืฆืืจืขืจ ืืื ืงืึธื ืกืืืขืจ ืกืขืืืื ืืก.
ืคึผืจืึธืืืฆืืจืขืจ:
- ืึทืงืก = ืึทืืข
- ืจืืืจืืื> 0
- ืขื ืึทืืืข.ืืืขืืคึผืึธืืขื ืกืข = ืืืช
- max.in.flight.requests.per.connection โค 5 (1 ืคึฟืึทืจ ืึธืจืืขืจืื ืฉืืงื)
- transactional.id = ${ืึทืคึผืคึผืืืงืึทืืืึธื ื ืึธืืขื}-${ืืึธืกืื ืึทืืข}
ืงืึธื ืกืืืขืจ:
- isolation.level = read_committed
ืฆื ืืื ืึทืืืื ืขืจืจืึธืจืก ืืื ืฆืืงืื ืคึฟื ืึทืคึผืืึทืงืืืฉืึทื ื, ืืืจ ืืขืืืื ืืื ืืืขืจ ืืืืืขื ืข ืจืึทืคึผืขืจ ืืืืขืจ ืื ืคืจืืืื ื ืงืึทื ืคืืืืขืจืืืฉืึทื, ืืื ืืืึทืืืขืก ืคึฟืึทืจ ืขืืืขืืข ืคืื โโืื ืืืกืืขื ืคึผืึทืจืึทืืขืืขืจืก ืืขื ืขื ืฉืืื ืืึทืฉืืืื.
ืืึธ ืืขื ืขื ืึท ืคึผืึธืจ ืคืื ืืึทืืขืจืืึทืืก ืคึฟืึทืจ ืืื-ืืขืจื ืขื:
ืืงืืจ: www.habr.com