[ 
https://issues.apache.org/jira/browse/KAFKA-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18081327#comment-18081327
 ] 

Matthias J. Sax commented on KAFKA-1639:
----------------------------------------

Wow... This is still something I would like to do :) 

> 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
>            Priority: Major
>
> 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
(v8.20.10#820010)

Reply via email to