Я пытаюсь использовать ConsumerRecordFactory, предоставленный Kafka Streams, следуя главным образом...