[ https://issues.apache.org/jira/browse/KAFKA-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137751#comment-14137751 ]
Chris Riccomini commented on KAFKA-1639: ---------------------------------------- One point of discussion is whether the control message should be a full-blown message, or just a field in an existing message's payload. A full message seems like a more general solution to me. > Support control messages in Kafka > --------------------------------- > > Key: KAFKA-1639 > URL: https://issues.apache.org/jira/browse/KAFKA-1639 > Project: Kafka > Issue Type: Improvement > Reporter: Chris Riccomini > > The current transactionality proposal > (https://cwiki.apache.org/confluence/display/KAFKA/Transactional+Messaging+in+Kafka) > and implementation use control messages to handle transactions in Kafka. > Kafka traditionally hasn't had control messages in its topics. > Transactionality (as it's implemented) introduces this pattern, but appears > to do so in a very specific fashion (control messages only for transactions). > It seems to me that a good approach to control messages would be to > generalize the control message model in Kafka to support not just transaction > control messages, but arbitrary control messages. On the producer side, > arbitrary control messages should be allowed to be sent, and on the consumer > side, these control messages should be dropped by default. > Just like transactionality, this would let frameworks (e.g. Samza) and other > app-specific implementations take advantage of in-topic control messages (as > opposed to out of band control messages) without any impact on existing > consumers. -- This message was sent by Atlassian JIRA (v6.3.4#6332)