[ 
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)

Reply via email to